libs/Torus/Core.pm

##    ------------------------------------------------------------------------
##    $Id: Core.pm,v 1.3 2003/01/19 03:35:25 joko Exp $
##    ------------------------------------------------------------------------
##    $Log: Core.pm,v $
##    Revision 1.3  2003/01/19 03:35:25  joko
##    + added cvs-header
##    ------------------------------------------------------------------------


package Torus::Core;

use strict;
use warnings;

=pod
use base qw( 
  DesignPattern::Object
  DesignPattern::Object::Logger
);
=cut

use mixin::with qw( Torus );


use Data::Dumper;

use Data::Storage;
use Data::Storage::Locator;
use Data::Transfer::Sync;


# get logger instance
my $logger = Log::Dispatch::Config->instance;

my $DEBUGLEVEL;
my $TRACELEVEL;
my $bool_started;

sub initDebugLevel {
  my $self = shift;

  $DEBUGLEVEL = $self->{config}->get("debug_level");
  $TRACELEVEL = $self->{config}->get("trace_level");

 }


sub addItem {

  my $torusObjectType = shift;
  my $mapiEntry = shift;
  my $basedn = shift;
  my $ldapEntry;

  if (!$bool_started) {
    Torus::Driver::ldap::connectStore();
  }

  $bool_started = 1;

  if ($DEBUGLEVEL > 3) {
    print STDOUT "=" x 3, "   ", __PACKAGE__, "   ", "=" x 30, "\n";
    print STDOUT "recieved torus-object (type=$torusObjectType)", "\n";
    print STDOUT "trying to write to (basedn='$basedn')", "\n";
  }

  if ($torusObjectType eq 'MapiContact') {
    $basedn = Torus::Driver::ldap::createOuSafe($basedn);
    my $entry = Torus::Driver::ldap::prepareEntry($basedn, $mapiEntry);
    if (my $result = Torus::Driver::ldap::addEntry($entry)) {
      #my $error = 0;
      #$error = 1 if $result->code >= 0;
      #Torus::Driver::ldap::traceEntry($mapiEntry, $entry, { error => $error, prefix => $result->error }) if $TRACELEVEL >= 2;
      #undef $result;
      Torus::Driver::ldap::processResult($entry->{identifier}, $result);
    }
  }

}

sub startSync {

  my $self = shift;
  my $opts = shift;

#print Dumper($self);

#print Dumper($opts);
#exit;

  my $host = $self->{config}->get("ldapserver_host");
  my $binddn = $self->{config}->get("ldapserver_binddn");
  my $pass = $self->{config}->get("ldapserver_pass");
  my $basedn = $self->{config}->get("ldapserver_basedn");
  
  my $dsn = "ldap:host=$host;binddn='$binddn';pass=$pass";
  $logger->notice(__PACKAGE__ . "->startSync: using dsn: $dsn");

  # connect to LDAP
    my $ldapLocator = Data::Storage::Locator->new(
      ldap => {
        type => "NetLDAP",
        #dsn => "ldap:host=192.168.1.56;binddn='cn=root, dc=labnet, dc=de';pass=Geheim",
        #dsn => "ldap:host=192.168.10.150;binddn='cn=root, o=netfrag.org, c=de';pass=secret",
        dsn => $dsn,
        #basedn => "o=netfrag.org, c=de",
        basedn => $basedn,
        #schema => 'BizWorks::BackendDbSchema',
        #classnames => [qw( SystemEvent LangText )],
        #classnames => [qw( SystemEvent Person Address LangText )],
        #test_availability => 1,
        #test_integrity => 1,
        #test_emptyness => 1,
        # TODO: re-enable this! (multiple-target-logging!)
        #logger => 1,
        want_transactions => 0,
        syncable => 1,
      },
    );
    my $ldapStorage = Data::Storage->new($ldapLocator);
    $ldapStorage->connect();

  # connect to MAPI
    my $mapiLocator = Data::Storage::Locator->new(
      outlook => {
        type => "MAPI",
        #dsn => "ldap:host=192.168.1.56;binddn='cn=root, dc=labnet, dc=de';pass=Geheim",
        #dsn => "ldap:host=192.168.10.150;binddn='cn=root, o=netfrag.org, c=de';pass=secret",
        #dsn => $dsn,
        #basedn => "o=netfrag.org, c=de",
        #basedn => $basedn,
        #schema => 'BizWorks::BackendDbSchema',
        #classnames => [qw( SystemEvent LangText )],
        #classnames => [qw( SystemEvent Person Address LangText )],
        #test_availability => 1,
        #test_integrity => 1,
        #test_emptyness => 1,
        # TODO: re-enable this! (multiple-target-logging!)
        #logger => 1,
        #want_transactions => 0,
        syncable => 1,
        showProfileChooser => $self->{config}->get("mapi_showProfileChooser"),
        ProfileName => $self->{config}->get("mapi_ProfileName"),
        ProfilePass => $self->{config}->get("mapi_ProfilePass"),
      },
    );
    my $mapiStorage = Data::Storage->new($mapiLocator);
    $mapiStorage->connect();
  

  # create a new synchronization object
  my $sync = Data::Transfer::Sync->new();

  # read, mungle & check the options
    $sync->prepareOptionsV2($opts);

    if (!$sync->checkOptionsV2()) {
      $logger->critical( __PACKAGE__ . "->startSync: 'Data::Transfer::Sync::checkOptions' failed.");
      return;
    }

#print Dumper($opts);


=pod
  # branch to execution path for special targets
  # detect for option 'handler' which could be a CODEref
    if ($opts->{handler} && ref $opts->{handler} eq 'CODE') {
      $logger->info( __PACKAGE__ . "->startSync: Running (special handler code - no generic sync!) on '$opts->{target}' with MODE $opts->{mode}, NODE $opts->{target_node}");
      $opts->{handler}->($self, $opts);
      return;
    }
=cut
  
  # configure synchronization-object
  $sync->configureV2(
      #L => $self->{bizWorks}->{$opts->{source}},
    source => {
      storage => {
        handle => $mapiStorage,
        writeProtected => 1,
      },
    },
    #R => $self->{bizWorks}->{$opts->{target}},
    target => {
      storage => {
        handle => $ldapStorage,
        idAuthority => 1,
        checksumAuthority => 1,
        writeProtected => 0,
      },
    },
    verbose => 1,
  );
  
  # patch options
  #$opts->{source} = "L:$opts->{source_node}" if $opts->{source_node};
  #$opts->{target} = "R:$opts->{target_node}" if $opts->{target_node};

#print Dumper($opts);

#  $sync->syncNodes($opts);
  $sync->syncNodes();

  #$mapiStorage->disconnect();

}

1;
1	joko	1.3	## ------------------------------------------------------------------------
2	joko	1.4	## $Id: Core.pm,v 1.3 2003/01/19 03:35:25 joko Exp $
3	joko	1.3	## ------------------------------------------------------------------------
4	joko	1.4	## $Log: Core.pm,v $
5			## Revision 1.3 2003/01/19 03:35:25 joko
6			## + added cvs-header
7	joko	1.3	## ------------------------------------------------------------------------
8
9
10	joko	1.1	package Torus::Core;
11
12	joko	1.4	use strict;
13			use warnings;
14
15			=pod
16	joko	1.2	use base qw(
17			DesignPattern::Object
18			DesignPattern::Object::Logger
19			);
20	joko	1.4	=cut
21
22			use mixin::with qw( Torus );
23	joko	1.1
24
25	joko	1.3	use Data::Dumper;
26
27			use Data::Storage;
28			use Data::Storage::Locator;
29	joko	1.2	use Data::Transfer::Sync;
30
31	joko	1.4
32			# get logger instance
33	joko	1.2	my $logger = Log::Dispatch::Config->instance;
34
35	joko	1.4	my $DEBUGLEVEL;
36			my $TRACELEVEL;
37			my $bool_started;
38
39			sub initDebugLevel {
40			my $self = shift;
41
42			$DEBUGLEVEL = $self->{config}->get("debug_level");
43			$TRACELEVEL = $self->{config}->get("trace_level");
44
45			}
46
47	joko	1.1
48
49
50			sub addItem {
51
52			my $torusObjectType = shift;
53			my $mapiEntry = shift;
54			my $basedn = shift;
55			my $ldapEntry;
56
57			if (!$bool_started) {
58			Torus::Driver::ldap::connectStore();
59			}
60
61			$bool_started = 1;
62
63			if ($DEBUGLEVEL > 3) {
64			print STDOUT "=" x 3, " ", __PACKAGE__, " ", "=" x 30, "\n";
65			print STDOUT "recieved torus-object (type=$torusObjectType)", "\n";
66			print STDOUT "trying to write to (basedn='$basedn')", "\n";
67			}
68
69			if ($torusObjectType eq 'MapiContact') {
70			$basedn = Torus::Driver::ldap::createOuSafe($basedn);
71			my $entry = Torus::Driver::ldap::prepareEntry($basedn, $mapiEntry);
72			if (my $result = Torus::Driver::ldap::addEntry($entry)) {
73			#my $error = 0;
74			#$error = 1 if $result->code >= 0;
75			#Torus::Driver::ldap::traceEntry($mapiEntry, $entry, { error => $error, prefix => $result->error }) if $TRACELEVEL >= 2;
76			#undef $result;
77			Torus::Driver::ldap::processResult($entry->{identifier}, $result);
78			}
79			}
80	joko	1.2
81			}
82
83			sub startSync {
84
85			my $self = shift;
86			my $opts = shift;
87
88	joko	1.4	#print Dumper($self);
89
90	joko	1.3	#print Dumper($opts);
91			#exit;
92
93	joko	1.4	my $host = $self->{config}->get("ldapserver_host");
94			my $binddn = $self->{config}->get("ldapserver_binddn");
95			my $pass = $self->{config}->get("ldapserver_pass");
96			my $basedn = $self->{config}->get("ldapserver_basedn");
97	joko	1.3
98			my $dsn = "ldap:host=$host;binddn='$binddn';pass=$pass";
99	joko	1.4	$logger->notice(__PACKAGE__ . "->startSync: using dsn: $dsn");
100	joko	1.3
101	joko	1.4	# connect to LDAP
102			my $ldapLocator = Data::Storage::Locator->new(
103			ldap => {
104			type => "NetLDAP",
105			#dsn => "ldap:host=192.168.1.56;binddn='cn=root, dc=labnet, dc=de';pass=Geheim",
106			#dsn => "ldap:host=192.168.10.150;binddn='cn=root, o=netfrag.org, c=de';pass=secret",
107			dsn => $dsn,
108			#basedn => "o=netfrag.org, c=de",
109			basedn => $basedn,
110			#schema => 'BizWorks::BackendDbSchema',
111			#classnames => [qw( SystemEvent LangText )],
112			#classnames => [qw( SystemEvent Person Address LangText )],
113			#test_availability => 1,
114			#test_integrity => 1,
115			#test_emptyness => 1,
116			# TODO: re-enable this! (multiple-target-logging!)
117			#logger => 1,
118			want_transactions => 0,
119			syncable => 1,
120			},
121			);
122			my $ldapStorage = Data::Storage->new($ldapLocator);
123			$ldapStorage->connect();
124
125			# connect to MAPI
126			my $mapiLocator = Data::Storage::Locator->new(
127			outlook => {
128			type => "MAPI",
129			#dsn => "ldap:host=192.168.1.56;binddn='cn=root, dc=labnet, dc=de';pass=Geheim",
130			#dsn => "ldap:host=192.168.10.150;binddn='cn=root, o=netfrag.org, c=de';pass=secret",
131			#dsn => $dsn,
132			#basedn => "o=netfrag.org, c=de",
133			#basedn => $basedn,
134			#schema => 'BizWorks::BackendDbSchema',
135			#classnames => [qw( SystemEvent LangText )],
136			#classnames => [qw( SystemEvent Person Address LangText )],
137			#test_availability => 1,
138			#test_integrity => 1,
139			#test_emptyness => 1,
140			# TODO: re-enable this! (multiple-target-logging!)
141			#logger => 1,
142			#want_transactions => 0,
143			syncable => 1,
144			showProfileChooser => $self->{config}->get("mapi_showProfileChooser"),
145			ProfileName => $self->{config}->get("mapi_ProfileName"),
146			ProfilePass => $self->{config}->get("mapi_ProfilePass"),
147			},
148			);
149			my $mapiStorage = Data::Storage->new($mapiLocator);
150			$mapiStorage->connect();
151	joko	1.2
152
153			# create a new synchronization object
154			my $sync = Data::Transfer::Sync->new();
155
156	joko	1.3	# read, mungle & check the options
157			$sync->prepareOptionsV2($opts);
158	joko	1.2
159	joko	1.3	if (!$sync->checkOptionsV2()) {
160			$logger->critical( __PACKAGE__ . "->startSync: 'Data::Transfer::Sync::checkOptions' failed.");
161			return;
162			}
163	joko	1.2
164			#print Dumper($opts);
165
166
167	joko	1.3	=pod
168	joko	1.2	# branch to execution path for special targets
169			# detect for option 'handler' which could be a CODEref
170			if ($opts->{handler} && ref $opts->{handler} eq 'CODE') {
171			$logger->info( __PACKAGE__ . "->startSync: Running (special handler code - no generic sync!) on '$opts->{target}' with MODE $opts->{mode}, NODE $opts->{target_node}");
172			$opts->{handler}->($self, $opts);
173			return;
174			}
175	joko	1.3	=cut
176	joko	1.2
177			# configure synchronization-object
178	joko	1.3	$sync->configureV2(
179	joko	1.2	#L => $self->{bizWorks}->{$opts->{source}},
180	joko	1.3	source => {
181			storage => {
182			handle => $mapiStorage,
183			writeProtected => 1,
184			},
185			},
186			#R => $self->{bizWorks}->{$opts->{target}},
187			target => {
188			storage => {
189			handle => $ldapStorage,
190			idAuthority => 1,
191			checksumAuthority => 1,
192			writeProtected => 0,
193			},
194	joko	1.2	},
195			verbose => 1,
196			);
197
198			# patch options
199	joko	1.4	#$opts->{source} = "L:$opts->{source_node}" if $opts->{source_node};
200			#$opts->{target} = "R:$opts->{target_node}" if $opts->{target_node};
201	joko	1.2
202			#print Dumper($opts);
203
204	joko	1.4	# $sync->syncNodes($opts);
205			$sync->syncNodes();
206
207			#$mapiStorage->disconnect();
208	joko	1.1
209			}
210
211			1;
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26