Changeset 198 for trunk/lib


Ignore:
Timestamp:
04/15/09 03:51:26 (15 years ago)
Author:
nanardon
Message:
  • use new commit() and rollback()
  • add add standalone create_poll function
Location:
trunk/lib/Vote
Files:
9 edited

Legend:

Unmodified
Added
Removed

  • trunk/lib/Vote/Controller/Admin.pm

    r190 r198  
    2424sub begin : Private { 
    2525    my ( $self, $c, @args ) = @_; 
    26     $c->model('Vote')->db->rollback; 
     26    $c->model('Vote')->rollback; 
    2727} 
    2828 
    … …  
    4343        if ($c->req->param('addch')) { 
    4444            $vote->vote_add_choice($id, $c->req->param('addch')) 
    45                 and $vote->db->commit; 
     45                and $vote->commit; 
    4646        } elsif ($c->req->param('delch')) { 
    4747            $vote->delete_choice($c->req->param('delch')) 
    48                 and $vote->db->commit; 
     48                and $vote->commit; 
    4949        } elsif ($c->req->param('pollparam')) { 
    5050            if ($c->req->param('dstart')) { 
    … …  
    7777                grep { exists($c->req->params->{$_}) } 
    7878                qw(label description start end choice_count free_choice) 
    79             ) and $vote->db->commit; 
     79            ) and $vote->commit; 
    8080        } elsif ($c->req->param('encrypted')) { 
    8181            my $passphrase = $c->req->param('passphrase') || 
    8282                $c->session->{'vpass' . $c->stash->{voteid}}; 
    8383            $poll->gen_poll_keys($passphrase) 
    84                 and $vote->db->commit; 
     84                and $vote->commit; 
    8585        } elsif ($c->req->param('notcrypted')) { 
    8686            $poll->param(public_key => undef, private_key => undef) 
    87                 and $vote->db->commit; 
     87                and $vote->commit; 
    8888        } 
    8989    }; 
    … …  
    9595                $upload->fh, 
    9696                $c->req->param('delete'), 
    97             ) and $vote->db->commit; 
     97            ) and $vote->commit; 
    9898        } elsif($c->req->param('delvoting')) { 
    9999            $vote->delete_voting($c->req->param('delvoting')) 
    100                 and $vote->db->commit; 
     100                and $vote->commit; 
    101101        } elsif ($c->req->param('mail')) { 
    102102            $vote->addupd_voting($id, $c->req->param('mail'), $c->req->param('id')) 
    103                 and $vote->db->commit; 
     103                and $vote->commit; 
    104104        } elsif($c->req->param('mailpasswd')) { 
    105105            # TODO 
    … …  
    137137            } elsif($c->req->param($bid) eq 'invalid') { 
    138138                $vote->mark_ballot_invalid($bid, 1); 
    139                 $vote->db->commit; 
     139                $vote->commit; 
    140140            } elsif($c->req->param($bid) eq 'valid') { 
    141141                $vote->mark_ballot_invalid($bid, 0); 
    142                 $vote->db->commit; 
     142                $vote->commit; 
    143143            } 
    144144        } 

  • trunk/lib/Vote/Controller/Ballot.pm

    r181 r198  
    2424sub begin : Private { 
    2525    my ( $self, $c ) = @_; 
    26     $c->model('Vote')->db->rollback; 
     26    $c->model('Vote')->rollback; 
    2727} 
    2828 

  • trunk/lib/Vote/Controller/Newpoll.pm

    r186 r198  
    2424sub begin : Private { 
    2525    my ( $self, $c ) = @_; 
    26     $c->model('Vote')->db->rollback; 
    27     $c->model('Vote')->clean_old_poll_request and $c->model('Vote')->db->commit; 
     26    $c->model('Vote')->rollback; 
     27    $c->model('Vote')->clean_old_poll_request and $c->model('Vote')->commit; 
    2828} 
    2929 

  • trunk/lib/Vote/Controller/Root.pm

    r190 r198  
    2929sub begin : Private { 
    3030    my ( $self, $c ) = @_; 
    31     $c->model('Vote')->db->rollback; 
     31    $c->model('Vote')->rollback; 
    3232} 
    3333 

  • trunk/lib/Vote/Controller/Vote.pm

    r184 r198  
    2424sub begin : Private { 
    2525    my ( $self, $c ) = @_; 
    26     $c->model('Vote')->db->rollback; 
     26    $c->model('Vote')->rollback; 
    2727} 
    2828 

  • trunk/lib/Vote/DB.pm

    r194 r198  
    316316    my $rinfo = $self->poll_request_info($rid) or return; 
    317317 
     318    $self->create_poll($rinfo->{mail}, $rinfo->{label}, $passwd); 
     319     
     320    my $delreq = $self->db->prepare_cached( 
     321        q{delete from poll_request where id = ?} 
     322    ); 
     323 
     324    $delreq->execute($rid); 
     325    $self->commit; 
     326} 
     327 
     328sub create_poll { 
     329    my ($self, $mail, $label, $passwd) = @_; 
     330 
    318331    my $encpasswd = $self->gen_enc_passwd($passwd); 
    319332 
    … …  
    328341    ); 
    329342 
    330     $newpoll->execute($newpollid, $rinfo->{label}, $rinfo->{mail}, $encpasswd); 
     343    $newpoll->execute($newpollid, $label, $mail, $encpasswd); 
    331344    # set some default 
    332345    $self->poll($newpollid)->setup() or do { 
    333         $self->db->rollback; 
     346        $self->rollback; 
    334347        return; 
    335348    }; 
    336349 
    337     my $delreq = $self->db->prepare_cached( 
    338         q{delete from poll_request where id = ?} 
    339     ); 
    340  
    341     $delreq->execute($rid); 
    342     $self->db->commit; 
    343350 
    344351    $newpollid 
    345352} 
     353 
    346354 
    347355sub create_poll_request { 
    … …  
    356364 
    357365    $addreq->execute($reqid, $info{label}, $info{mail}); 
    358     $self->db->commit; 
     366    $self->commit; 
    359367    $reqid; 
    360368} 

  • trunk/lib/Vote/DB/Poll.pm

    r196 r198  
    6060        $sth->execute((map { $attr{$_} } grep { exists $attr{$_} } @online_f), $self->voteid) 
    6161            or do { 
    62             $self->db->rollback; 
     62            $self->rollback; 
    6363            return; 
    6464        }; 
    … …  
    264264 
    265265    $sth->execute($self->voteid, $label) or do { 
    266         $self->db->rollback; 
     266        $self->rollback; 
    267267        return; 
    268268    }; 
    … …  
    292292    ); 
    293293    $sth->execute($vinfo->{key}, $referal) or do { 
    294         $self->db->rollback; 
     294        $self->rollback; 
    295295        return; 
    296296    }; 
    … …  
    306306        : $self->_register_ballot_clear($choice, $fchoice)) 
    307307        or do { 
    308             self->db->rollback; 
     308            self->rollback; 
    309309            return; 
    310310        }; 
    … …  
    323323    $uid ||= Vote::DB::common::gen_uid(); 
    324324    $addb->execute($uid, $self->voteid, scalar(@{$fchoice || []}) ? undef : 'f') or do { 
    325         self->db->rollback; 
     325        self->rollback; 
    326326        return; 
    327327    }; 
    328328 
    329329    $self->_register_ballot_items($uid, $choice, $fchoice) or do { 
    330         self->db->rollback; 
     330        self->rollback; 
    331331        return; 
    332332    }; 
    … …  
    357357    foreach (@{ $choice || []}) { 
    358358        $addbc->execute($uid, $_, 't') or do { 
    359             $self->db->rollback; 
     359            $self->rollback; 
    360360            return; 
    361361        }; 
    … …  
    365365        my $chkey = $self->find_choice_key($_); 
    366366        $addbc->execute($uid, $_, $chkey ? 't' : 'f') or do { 
    367             $self->db->rollback; 
     367            $self->rollback; 
    368368            return; 
    369369        }; 
    … …  
    421421    my $upd = $self->db->prepare_cached(q{update ballot_enc set decrypted = true where id = ?}); 
    422422    if ($upd->execute($ballotid)) { 
    423         $self->db->commit; 
     423        $self->commit; 
    424424        return; 
    425425    } else { 
    426         $self->db->rollback; 
     426        $self->rollback; 
    427427        return 1; 
    428428    } 
    … …  
    451451    } 
    452452    # everything went fine, saving! 
    453     $self->db->commit; 
     453    $self->commit; 
    454454 
    455455     
    … …  
    715715    ); 
    716716 
    717     $sth->execute($self->voteid, $from, $to) or $self->db->rollback; 
    718     $self->db->commit; 
     717    $sth->execute($self->voteid, $from, $to) or $self->rollback; 
     718    $self->commit; 
    719719} 
    720720 
    … …  
    754754        my ($mail, $name) = split(';', $line); 
    755755        $mail or do { 
    756             $self->db->rollback; 
     756            $self->rollback; 
    757757            return; 
    758758        }; 

  • trunk/lib/Vote/DB/Voting.pm

    r182 r198  
    9090 
    9191    $upd_voting->execute($encpasswd, $self->votingkey); 
    92     $self->db->commit; 
     92    $self->commit; 
    9393    $passwd 
    9494} 

  • trunk/lib/Vote/DB/common.pm

    r197 r198  
    9898        ) 
    9999    ); 
    100     $res or $self->db->rollback; 
     100    $res or $self->rollback; 
    101101} 
    102102 
    … …  
    111111    ); 
    112112    $sth->execute or do { 
    113         $self->db->rollback; 
     113        $self->rollback; 
    114114        return; 
    115115    }; 
Note: See TracChangeset for help on using the changeset viewer.