rfe #640: Refactored autocommit and autocomment

Autocommit assets like CS posts or Calendar Events can now be added before the
parent is committed.  They will go into the same version tag as their parent.
This commit is contained in:
Graham Knop 2008-10-22 16:04:10 +00:00
parent 71fc839c83
commit 99a9da626d
22 changed files with 218 additions and 259 deletions

View file

@ -25,6 +25,9 @@
- rfe #746: use the menu title in asset manager - rfe #746: use the menu title in asset manager
- rfe #549: New macro for checking spectre status. VersionTag::RequestCommit and Operation::VestionTag::www_commitVertionTag now both check for spectre status before trying to commit. - rfe #549: New macro for checking spectre status. VersionTag::RequestCommit and Operation::VestionTag::www_commitVertionTag now both check for spectre status before trying to commit.
- rfe #637: Alphabetize wiki items under a keyword? - rfe #637: Alphabetize wiki items under a keyword?
- Autocommit assets like CS posts or Calendar Events can now be added before the
parent is committed. They will go into the same version tag as their parent.
- rfe #640: Refactored autocommit and autocomment
7.6.1 7.6.1

View file

@ -2550,35 +2550,17 @@ sub www_editSave {
$object->updateHistory("edited"); $object->updateHistory("edited");
# Handle Save & Commit button # we handle auto commit assets here in case they didn't handle it themselves
if ($self->session->form->process("saveAndCommit") ne "") { if ($object->getAutoCommitWorkflowId && $self->hasBeenCommitted) {
if ($self->session->setting->get("skipCommitComments")) { $object->requestAutoCommit;
$self->session->http->setRedirect(
$self->getUrl("op=commitVersionTagConfirm;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)
);
}
else {
$self->session->http->setRedirect(
$self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)
);
}
return undef;
} }
# else, try to to auto commit
# Handle Auto Request Commit setting elsif(WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->setting->get("autoRequestCommit")) { override => scalar $self->session->form->process('saveAndCommit'),
# Make sure version tag hasn't already been committed by another process allowComments => 1,
my $versionTag = WebGUI::VersionTag->getWorking($self->session, "nocreate"); returnUrl => $self->getUrl,
})) {
if ($versionTag && $self->session->setting->get("skipCommitComments")) { return undef;
$versionTag->requestCommit;
}
elsif ($versionTag) {
$self->session->http->setRedirect(
$self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)
);
return undef;
}
} }
# Handle "saveAndReturn" button # Handle "saveAndReturn" button
@ -2600,12 +2582,11 @@ sub www_editSave {
$self->session->asset($object); $self->session->asset($object);
return $self->session->asset->$method(); return $self->session->asset->$method();
} }
$self->session->asset($object->getContainer); $self->session->asset($object->getContainer);
return $self->session->asset->www_view; return $self->session->asset->www_view;
} }
#------------------------------------------------------------------- #-------------------------------------------------------------------

View file

@ -16,12 +16,12 @@ our $VERSION = "0.0.0";
use Tie::IxHash; use Tie::IxHash;
use Carp qw(croak); use Carp qw(croak);
use Storable qw(nfreeze thaw);
use WebGUI::International; use WebGUI::International;
use WebGUI::Asset::Template; use WebGUI::Asset::Template;
use WebGUI::Form; use WebGUI::Form;
use WebGUI::Storage::Image; use WebGUI::Storage::Image;
use Storable;
use base 'WebGUI::Asset'; use base 'WebGUI::Asset';
@ -275,8 +275,7 @@ sub generateRecurringEvents {
$properties->{startTime} = $startDate->toDatabaseTime; $properties->{startTime} = $startDate->toDatabaseTime;
$properties->{endTime} = $endDate->toDatabaseTime; $properties->{endTime} = $endDate->toDatabaseTime;
} }
my $newEvent = $parent->addChild($properties); my $newEvent = $parent->addChild($properties, undef, undef, { skipAutoCommitWorkflows => 1 });
$newEvent->requestAutoCommit;
} }
} }
@ -298,8 +297,12 @@ By specifying this method, you activate this feature.
sub getAutoCommitWorkflowId { sub getAutoCommitWorkflowId {
my $self = shift; my $self = shift;
return $self->getParent->get('workflowIdCommit') my $parent = $self->getParent;
|| $self->session->setting->get('defaultVersionTagWorkflow'); if ($parent->hasBeenCommitted) {
return $parent->get('workflowIdCommit')
|| $self->session->setting->get('defaultVersionTagWorkflow');
}
return undef;
} }
@ -1469,7 +1472,7 @@ sub processPropertiesFromFormPost {
my $self = shift; my $self = shift;
$self->SUPER::processPropertiesFromFormPost; # Updates the event $self->SUPER::processPropertiesFromFormPost; # Updates the event
my $session = $self->session; my $session = $self->session;
my $form = $self->session->form; my $form = $session->form;
### Verify the form was filled out correctly... ### Verify the form was filled out correctly...
my @errors; my @errors;
@ -1489,6 +1492,17 @@ sub processPropertiesFromFormPost {
return \@errors; return \@errors;
} }
# Since we may be adding more events, set out version tag to be active if needed
# Leave the original version tag available, we will need to reactivate it before returning
warn "trying to activate version tag\n";
my $activeVersionTag = WebGUI::VersionTag->getWorking($session, 'nocreate');
# if our version tag is active, we don't need a new one, and don't need to reactivate anything later
if ($activeVersionTag && $activeVersionTag->getId eq $self->get('tagId')) {
undef $activeVersionTag;
}
else {
WebGUI::VersionTag->new($session, $self->get('tagId'))->setWorking;
}
### Form is verified ### Form is verified
# Events are always hidden from navigation # Events are always hidden from navigation
@ -1518,16 +1532,16 @@ sub processPropertiesFromFormPost {
my $dtStart my $dtStart
= WebGUI::DateTime->new($session, = WebGUI::DateTime->new($session,
mysql => $self->get("startDate") . " " . $self->get("startTime"), mysql => $self->get("startDate") . " " . $self->get("startTime"),
time_zone => $tz, time_zone => $tz,
); );
my $dtEnd my $dtEnd
= WebGUI::DateTime->new($session, = WebGUI::DateTime->new($session,
mysql => $self->get("endDate") . " " . $self->get("endTime"), mysql => $self->get("endDate") . " " . $self->get("endTime"),
time_zone => $tz, time_zone => $tz,
); );
$self->update({ $self->update({
startDate => $dtStart->toDatabaseDate, startDate => $dtStart->toDatabaseDate,
startTime => $dtStart->toDatabaseTime, startTime => $dtStart->toDatabaseTime,
endDate => $dtEnd->toDatabaseDate, endDate => $dtEnd->toDatabaseDate,
@ -1603,7 +1617,6 @@ sub processPropertiesFromFormPost {
$self->setRelatedLinks(\@rel_link_saves); $self->setRelatedLinks(\@rel_link_saves);
# Determine if the pattern has changed # Determine if the pattern has changed
if ($form->param("recurType")) { if ($form->param("recurType")) {
# Create the new recurrence hash # Create the new recurrence hash
@ -1617,16 +1630,19 @@ sub processPropertiesFromFormPost {
# Pattern keys # Pattern keys
if (nfreeze(\%recurrence_new) ne nfreeze(\%recurrence_old)) { if (Storable::freeze(\%recurrence_new) ne Storable::freeze(\%recurrence_old)) {
# Delete all old events and create new ones # Delete all old events and create new ones
my $old_id = $self->get("recurId"); my $old_id = $self->get("recurId");
# Set the new recurrence pattern # Set the new recurrence pattern
if (%recurrence_new) { if (%recurrence_new) {
my $new_id = $self->setRecurrence(\%recurrence_new); my $new_id = $self->setRecurrence(\%recurrence_new);
return ["There is something wrong with your recurrence pattern."] if (! $new_id) {
unless $new_id; $activeVersionTag->setWorking
if $activeVersionTag;
return ["There is something wrong with your recurrence pattern."];
}
# Generate the new recurring events # Generate the new recurring events
$self->generateRecurringEvents(); $self->generateRecurringEvents();
} }
@ -1649,7 +1665,7 @@ sub processPropertiesFromFormPost {
# TODO: Give users a form property to decide what events to update # TODO: Give users a form property to decide what events to update
# TODO: Make a workflow activity to do this, so that updating # TODO: Make a workflow activity to do this, so that updating
# 1 million events doesn't kill the server. # 1 million events doesn't kill the server.
# Just update related events # Just update related events
my %properties = %{ $self->get }; my %properties = %{ $self->get };
delete $properties{startDate}; delete $properties{startDate};
delete $properties{endDate}; delete $properties{endDate};
@ -1663,23 +1679,21 @@ sub processPropertiesFromFormPost {
}); });
for my $eventId (@{$events}) { for my $eventId (@{$events}) {
my $event = WebGUI::Asset->newByDynamicClass($session,$eventId); my $event = WebGUI::Asset->newByDynamicClass($session, $eventId);
# Add a revision # Add a revision
$properties{ startDate } = $event->get("startDate"); $properties{ startDate } = $event->get("startDate");
$properties{ endDate } = $event->get("endDate"); $properties{ endDate } = $event->get("endDate");
# addRevision returns the new revision # addRevision returns the new revision
$event = $event->addRevision(\%properties); $event = $event->addRevision(\%properties, undef, { skipAutoCommitWorkflows => 1 });
$event->requestAutoCommit();
} }
} }
} }
$activeVersionTag->setWorking
if $activeVersionTag;
# Finally, commit this event
delete $self->{_storageLocation}; delete $self->{_storageLocation};
$self->requestAutoCommit;
return undef; return undef;
} }

View file

@ -281,7 +281,12 @@ Returns the workflowId of the Gallery's approval workflow.
sub getAutoCommitWorkflowId { sub getAutoCommitWorkflowId {
my $self = shift; my $self = shift;
return $self->getGallery->get("workflowIdCommit"); my $gallery = $self->getGallery;
if ($gallery->hasBeenCommitted) {
return $gallery->get("workflowIdCommit")
|| $self->session->setting->get('defaultVersionTagWorkflow');
}
return undef;
} }
#---------------------------------------------------------------------------- #----------------------------------------------------------------------------
@ -683,8 +688,6 @@ sub processPropertiesFromFormPost {
} ); } );
} }
$self->requestAutoCommit;
return; return;
} }

View file

@ -195,25 +195,13 @@ sub editSave {
} }
$tempStorage->delete; $tempStorage->delete;
# deal with special commit rules if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->form->process("saveAndCommit") ne "") { override => scalar $self->session->form->process("saveAndCommit"),
if ($self->session->setting->get("skipCommitComments")) { allowComments => 1,
$self->session->http->setRedirect($self->getUrl("op=commitVersionTagConfirm;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)); returnUrl => $self->getUrl,
} })) {
else { return undef;
$self->session->http->setRedirect($self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)); };
}
return undef;
}
if ($self->session->setting->get("autoRequestCommit")) {
if ($self->session->setting->get("skipCommitComments")) {
WebGUI::VersionTag->getWorking($self->session)->requestCommit;
}
else {
$self->session->http->setRedirect($self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId));
return undef;
}
}
return $self->getParent->www_manageAssets if ($self->session->form->process("proceed") eq "manageAssets"); return $self->getParent->www_manageAssets if ($self->session->form->process("proceed") eq "manageAssets");
return $self->getParent->www_view; return $self->getParent->www_view;

View file

@ -332,8 +332,13 @@ sub getContentLastModified {
#------------------------------------------------------------------- #-------------------------------------------------------------------
sub getAutoCommitWorkflowId { sub getAutoCommitWorkflowId {
my $self = shift; my $self = shift;
return $self->getThread->getParent->get("approvalWorkflow"); my $cs = $self->getThread->getParent;
if ($cs->hasBeenCommitted) {
return $cs->get('approvalWorkflow')
|| $self->session->setting->get('defaultVersionTagWorkflow');
}
return undef;
} }
#------------------------------------------------------------------- #-------------------------------------------------------------------
@ -879,7 +884,6 @@ sub postProcess {
$size += $storage->getFileSize($file); $size += $storage->getFileSize($file);
} }
$self->setSize($size); $self->setSize($size);
$self->requestAutoCommit;
} }
#------------------------------------------------------------------- #-------------------------------------------------------------------

View file

@ -582,6 +582,14 @@ sub postProcess {
$self->SUPER::postProcess; $self->SUPER::postProcess;
} }
sub processPropertiesFromFormPost {
my $self = shift;
if ($self->isNew && $self->getParent->getValue('useCaptcha')) {
my $captcha = $self->session->form->process("captcha","Captcha");
return [ 'invalid captcha' ];
}
}
#------------------------------------------------------------------- #-------------------------------------------------------------------
sub purge { sub purge {

View file

@ -467,10 +467,7 @@ sub www_editDuplicate {
# Auto-commit our revision if necessary # Auto-commit our revision if necessary
# TODO: This needs to be handled automatically somehow... # TODO: This needs to be handled automatically somehow...
if ($session->setting->get("autoRequestCommit")) { WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session);
my $tag = WebGUI::VersionTag->getWorking($session)->requestCommit;
}
last DEF; last DEF;
} }
} }

View file

@ -117,7 +117,12 @@ sub definition {
#------------------------------------------------------------------- #-------------------------------------------------------------------
sub getAutoCommitWorkflowId { sub getAutoCommitWorkflowId {
my $self = shift; my $self = shift;
return $self->getWiki->get("approvalWorkflow"); my $wiki = $self->getWiki;
if ($wiki->hasBeenCommitted) {
return $wiki->get('approvalWorkflow')
|| $self->session->setting->get('defaultVersionTagWorkflow');
}
return undef;
} }
@ -266,9 +271,7 @@ sub processPropertiesFromFormPost {
} }
} }
# wiki pages are auto committed }
$self->requestAutoCommit;
}
#------------------------------------------------------------------- #-------------------------------------------------------------------

View file

@ -425,7 +425,7 @@ sub canAddEvent {
: $self->session->user : $self->session->user
; ;
return 1 if ( return 1 if (
$user->isInGroup( $self->get("groupIdEventEdit") ) $user->isInGroup( $self->get("groupIdEventEdit") )
); );
} }
@ -1755,26 +1755,6 @@ sub wrapIcal {
return join "\r\n ",@text; return join "\r\n ",@text;
} }
#-------------------------------------------------------------------
=head2 www_add ( )
Returns an error message if the collaboration system has not yet been posted.
=cut
sub www_add {
my $self = shift;
#Check to see if the asset has been committed
unless ($self->hasBeenCommitted ) {
my $i18n = WebGUI::International->new($self->session,"Asset_Calendar");
return $self->processStyle($i18n->get("asset not committed"));
}
return $self->SUPER::www_add( @_ );
}
#---------------------------------------------------------------------------- #----------------------------------------------------------------------------
=head2 www_edit ( ) =head2 www_edit ( )

View file

@ -1388,55 +1388,6 @@ sub view {
#------------------------------------------------------------------- #-------------------------------------------------------------------
=head2 www_add ( )
Returns an error message if the collaboration system has not yet been posted.
=cut
sub www_add {
my $self = shift;
#Check to see if the asset has been committed
unless ( $self->hasBeenCommitted ) {
my $i18n = WebGUI::International->new($self->session,"Asset_Collaboration");
return $self->processStyle($i18n->get("asset not committed"));
}
return $self->SUPER::www_add( @_ );
}
#-------------------------------------------------------------------
=head2 www_editSave ( )
We're extending www_editSave() here to deal with editing a post that has been denied by the approval process. Our change will reassign the old working tag of this post to the user so that they can edit it.
=cut
sub www_editSave {
my $self = shift;
my $session = $self->session;
my $className = $session->form->param("class");
#my $assetId = $self->session->form->param("assetId");
if($className eq "WebGUI::Asset::Post::Thread") {
my $assetId = $session->form->param("assetId");
if($assetId eq "new" && $self->getValue("useCaptcha")) {
my $captcha = $self->session->form->process("captcha","Captcha");
unless ($captcha) {
return $self->www_add;
}
}
}
return $self->SUPER::www_editSave();
}
#-------------------------------------------------------------------
=head2 www_search ( ) =head2 www_search ( )
The web method to display and use the forum search interface. The web method to display and use the forum search interface.

View file

@ -361,7 +361,12 @@ Returns the workflowId of the Gallery's approval workflow.
sub getAutoCommitWorkflowId { sub getAutoCommitWorkflowId {
my $self = shift; my $self = shift;
return $self->getParent->get("workflowIdCommit"); my $gallery = $self->getParent;
if ($gallery->hasBeenCommitted) {
return $gallery->get("workflowIdCommit")
|| $self->session->setting->get('defaultVersionTagWorkflow');
}
return undef;
} }
#---------------------------------------------------------------------------- #----------------------------------------------------------------------------
@ -708,8 +713,6 @@ sub processPropertiesFromFormPost {
return $errors if @$errors; return $errors if @$errors;
### Passes all checks ### Passes all checks
$self->requestAutoCommit;
} }
#---------------------------------------------------------------------------- #----------------------------------------------------------------------------

View file

@ -303,9 +303,7 @@ sub www_setContentPositions {
$self->addRevision({ $self->addRevision({
contentPositions=>$self->session->form->process("map") contentPositions=>$self->session->form->process("map")
}); });
if ($self->session->setting->get("autoRequestCommit")) { WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session);
WebGUI::VersionTag->getWorking($self->session)->requestCommit;
}
return "Map set: ".$self->session->form->process("map"); return "Map set: ".$self->session->form->process("map");
} }

View file

@ -385,21 +385,12 @@ sub www_importProducts {
} }
else { else {
$status_message = $i18n->get('import successful'); $status_message = $i18n->get('import successful');
##Copy and paste from WebGUI::Asset, www_editSave if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->setting->get("autoRequestCommit")) { allowComments => 1,
# Make sure version tag hasn't already been committed by another process returnUrl => $self->getUrl,
my $versionTag = WebGUI::VersionTag->getWorking($self->session, "nocreate"); })) {
return undef;
if ($versionTag && $self->session->setting->get("skipCommitComments")) { };
$versionTag->requestCommit;
}
elsif ($versionTag) {
$self->session->http->setRedirect(
$self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)
);
return undef;
}
}
} }
} }

View file

@ -392,26 +392,6 @@ sub view {
return $self->processTemplate($var, undef, $template); return $self->processTemplate($var, undef, $template);
} }
#-------------------------------------------------------------------
=head2 www_add ( )
Returns an error message if the collaboration system has not yet been posted.
=cut
sub www_add {
my $self = shift;
#Check to see if the asset has been committed
unless ($self->hasBeenCommitted ) {
my $i18n = WebGUI::International->new($self->session,"Asset_WikiMaster");
return $self->processStyle($i18n->get("asset not committed"));
}
return $self->SUPER::www_add( @_ );
}
#------------------------------------------------------------------- #-------------------------------------------------------------------
sub www_byKeyword { sub www_byKeyword {

View file

@ -304,14 +304,12 @@ sub www_editBranchSave {
} }
} }
} }
if ($self->session->setting->get("autoRequestCommit")) { if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->setting->get("skipCommitComments")) { allowComments => 1,
WebGUI::VersionTag->getWorking($self->session)->requestCommit; returnUrl => $self->getUrl,
} else { })) {
$self->session->http->setRedirect($self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)); return undef;
return undef; };
}
}
delete $self->{_parent}; delete $self->{_parent};
$self->session->asset($self->getParent); $self->session->asset($self->getParent);
return $self->getParent->www_manageAssets; return $self->getParent->www_manageAssets;

View file

@ -219,16 +219,12 @@ sub www_copy {
my $i18n = WebGUI::International->new($self->session, 'Asset'); my $i18n = WebGUI::International->new($self->session, 'Asset');
$newAsset->update({ title=>sprintf("%s (%s)",$self->getTitle,$i18n->get('copy'))}); $newAsset->update({ title=>sprintf("%s (%s)",$self->getTitle,$i18n->get('copy'))});
$newAsset->cut; $newAsset->cut;
if ($self->session->setting->get("autoRequestCommit")) { if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->setting->get("skipCommitComments")) { allowComments => 1,
WebGUI::VersionTag->getWorking($self->session)->requestCommit; returnUrl => $self->getUrl,
} else { })) {
$self->session->http->setRedirect($self->getUrl( return undef;
"op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId };
));
return undef;
}
}
return $self->session->asset($self->getContainer)->www_view; return $self->session->asset($self->getContainer)->www_view;
} }
@ -287,17 +283,14 @@ sub www_createShortcut {
if (! $isOnDashboard) { if (! $isOnDashboard) {
$child->cut; $child->cut;
} }
if ($self->session->setting->get("autoRequestCommit")) { if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->setting->get("skipCommitComments")) { allowComments => 1,
WebGUI::VersionTag->getWorking($self->session)->requestCommit; returnUrl => $self->getUrl,
} else { })) {
$self->session->http->setRedirect($self->getUrl( return undef;
"op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId };
));
return 1; if ($isOnDashboard) {
}
}
if ($isOnDashboard) {
return $self->getParent->www_view; return $self->getParent->www_view;
} else { } else {
$self->session->asset($self->getContainer); $self->session->asset($self->getContainer);

View file

@ -336,15 +336,12 @@ sub www_importPackage {
} }
} }
# Handle autocommit workflows # Handle autocommit workflows
if ($self->session->setting->get("autoRequestCommit")) { if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($self->session, {
if ($self->session->setting->get("skipCommitComments")) { allowComments => 1,
WebGUI::VersionTag->getWorking($self->session)->requestCommit; returnUrl => $self->getUrl,
} })) {
else { return undef;
$self->session->http->setRedirect($self->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($self->session)->getId)); };
return undef;
}
}
return $self->www_manageAssets(); return $self->www_manageAssets();
} }

View file

@ -371,21 +371,13 @@ sub www_manage {
} }
} }
# Handle Auto Request Commit setting # Handle autocommit workflows
if ($session->setting->get("autoRequestCommit")) { if (WebGUI::VersionTag->autoCommitWorkingIfEnabled($session, {
# Make sure version tag hasn't already been committed by another process allowComments => 1,
my $versionTag = WebGUI::VersionTag->getWorking($session, "nocreate"); returnUrl => $currentAsset->getUrl,
})) {
if ($versionTag && $session->setting->get("skipCommitComments")) { return undef;
$versionTag->requestCommit; };
}
elsif ($versionTag) {
$session->http->setRedirect(
$currentAsset->getUrl("op=commitVersionTag;tagId=".WebGUI::VersionTag->getWorking($session)->getId)
);
return undef;
}
}
# Show the page # Show the page
# i18n we'll need later # i18n we'll need later

View file

@ -315,9 +315,7 @@ sub www_upload {
$asset->getStorageLocation->addFileFromFilesystem($storage->getPath($filename)); $asset->getStorageLocation->addFileFromFilesystem($storage->getPath($filename));
$asset->applyConstraints; $asset->applyConstraints;
push(@assetIds, $asset->getId); push(@assetIds, $asset->getId);
if ($session->setting->get("autoRequestCommit")) { WebGUI::VersionTag->autoCommitWorkingIfEnabled($session);
WebGUI::VersionTag->getWorking($session)->requestCommit;
}
$storage->delete; $storage->delete;
return www_show($session, \@assetIds); return www_show($session, \@assetIds);
} }

View file

@ -37,6 +37,60 @@ These methods are available from this class:
=cut =cut
#-------------------------------------------------------------------
=head2 autoCommitWorkingIfEnabled ( $session, $options )
A class method that automatically commits the working version tag if auto commit is
enabled. Returns true if the version tag was committed.
=head3 $options
Hashref with options for how to do auto commit
=head4 override
Do autocommit even if not enabled for the site
=head4 allowComments
Whether to allow comments to be added. If enabled, instead of
committing directly, will set a redirect for the user to enter
a comment.
=head4 returnUrl
If allowComments is enabled, the URL to return to after committing
=cut
sub autoCommitWorkingIfEnabled {
my $class = shift;
my $session = shift;
my $options = shift || {};
# need a version tag to do any auto commit
my $versionTag = $class->getWorking($session, "nocreate");
return
unless $versionTag;
# auto commit assets
# save and commit button and site wide auto commit work the same
if (
$options->{override}
|| $session->setting->get("autoRequestCommit")
) {
if ($session->setting->get("skipCommitComments") || !$options->{allowComments}) {
$versionTag->requestCommit;
return 1;
}
else {
my $url = $options->{returnUrl} || $session->url->page;
$url = $session->url->append($url, "op=commitVersionTag;tagId=" . $versionTag->getId);
$session->http->setRedirect($url);
return 1;
}
}
}
#------------------------------------------------------------------- #-------------------------------------------------------------------
=head2 clearWorking ( ) =head2 clearWorking ( )

View file

@ -25,7 +25,7 @@ use WebGUI::DateTime;
use DateTime::TimeZone; use DateTime::TimeZone;
use LWP::UserAgent; use LWP::UserAgent;
use JSON qw(encode_json decode_json); use JSON ();
=head1 NAME =head1 NAME
@ -91,8 +91,8 @@ sub execute {
my $eventList = []; my $eventList = [];
my $feedList; my $feedList;
if ($instance->getScratch('events')) { if ($instance->getScratch('events')) {
$eventList = decode_json($instance->getScratch('events')); $eventList = JSON::from_json($instance->getScratch('events'));
$feedList = decode_json($instance->getScratch('feeds')); $feedList = JSON::from_json($instance->getScratch('feeds'));
} }
else { else {
my $ua = LWP::UserAgent->new(agent => "WebGUI"); my $ua = LWP::UserAgent->new(agent => "WebGUI");
@ -353,11 +353,22 @@ sub execute {
} }
} }
} }
my $currentVersionTag = WebGUI::VersionTag->getWorking($self->session, 1);
if ($currentVersionTag) {
$currentVersionTag->clearWorking;
}
my $ttl = $self->getTTL; my $ttl = $self->getTTL;
while (@$eventList) { while (@$eventList) {
if ($startTime + $ttl < time()) { if ($startTime + $ttl < time()) {
$instance->setScratch('events', encode_json($eventList)); $instance->setScratch('events', JSON::to_json($eventList));
$instance->setScratch('feeds', encode_json($feedList)); $instance->setScratch('feeds', JSON::to_json($feedList));
my $newVersionTag = WebGUI::VersionTag->getWorking($self->session, 1);
if ($newVersionTag) {
$newVersionTag->requestCommit;
}
if ($currentVersionTag) {
$currentVersionTag->setWorking;
}
return $self->WAITING; return $self->WAITING;
} }
my $eventData = shift @$eventList; my $eventData = shift @$eventList;
@ -376,7 +387,6 @@ sub execute {
if ($event) { if ($event) {
$event->update($properties); $event->update($properties);
$event->requestAutoCommit;
$feed->{updated}++; $feed->{updated}++;
} }
} }
@ -384,10 +394,16 @@ sub execute {
my $calendar = WebGUI::Asset->newByDynamicClass($self->session,$feed->{assetId}); my $calendar = WebGUI::Asset->newByDynamicClass($self->session,$feed->{assetId});
if (!defined $calendar) { if (!defined $calendar) {
$self->session->errorHandler->error("CalendarUpdateFeeds Activity: Calendar object failed to instanciate. Did you commit the calendar wobject?"); $self->session->errorHandler->error("CalendarUpdateFeeds Activity: Calendar object failed to instanciate. Did you commit the calendar wobject?");
my $newVersionTag = WebGUI::VersionTag->getWorking($self->session, 1);
if ($newVersionTag) {
$newVersionTag->requestCommit;
}
if ($currentVersionTag) {
$currentVersionTag->setWorking;
}
return $self->ERROR; return $self->ERROR;
} }
my $event = $calendar->addChild($properties); my $event = $calendar->addChild($properties, { skipAutoCommitWorkflows => 1});
$event->requestAutoCommit;
$feed->{added}++; $feed->{added}++;
if ($recur) { if ($recur) {
$event->setRecurrence($recur); $event->setRecurrence($recur);
@ -398,6 +414,13 @@ sub execute {
# TODO: Only update if last-updated field is # TODO: Only update if last-updated field is
# greater than the event's lastUpdated property # greater than the event's lastUpdated property
} }
my $newVersionTag = WebGUI::VersionTag->getWorking($self->session, 1);
if ($newVersionTag) {
$newVersionTag->requestCommit;
}
if ($currentVersionTag) {
$currentVersionTag->setWorking;
}
for my $feedId (keys %$feedList) { for my $feedId (keys %$feedList) {
my $feed = $feedList->{$feedId}; my $feed = $feedList->{$feedId};
$self->session->db->write("update Calendar_feeds set lastResult=?,lastUpdated=? where feedId=?", $self->session->db->write("update Calendar_feeds set lastResult=?,lastUpdated=? where feedId=?",