1 |
joko |
1.1 |
## ------------------------------------------------------------------------- |
2 |
|
|
## |
3 |
|
|
## $Id: Sync.pm,v 1.15 2003/01/20 16:58:07 joko Exp $ |
4 |
|
|
## |
5 |
|
|
## Copyright (c) 2002, 2003 Andreas Motl <andreas.motl@ilo.de> |
6 |
|
|
## |
7 |
|
|
## This module is licensed under the same terms as Perl itself. |
8 |
|
|
## |
9 |
|
|
## ------------------------------------------------------------------------- |
10 |
|
|
## $Log: Sync.pm,v $ |
11 |
|
|
## ------------------------------------------------------------------------- |
12 |
|
|
|
13 |
|
|
|
14 |
|
|
package Data::Transfer::Sync::Metadata::V1; |
15 |
|
|
|
16 |
|
|
use strict; |
17 |
|
|
use warnings; |
18 |
|
|
|
19 |
|
|
use mixin::with qw( Data::Transfer::Sync ); |
20 |
|
|
|
21 |
|
|
|
22 |
|
|
# start here |
23 |
|
|
|
24 |
|
|
use Data::Dumper; |
25 |
|
|
|
26 |
|
|
# get logger instance |
27 |
|
|
my $logger = Log::Dispatch::Config->instance; |
28 |
|
|
|
29 |
|
|
|
30 |
|
|
# TODO: refactor!!! take this list from already established/given metadata |
31 |
|
|
sub buildMetadata { |
32 |
|
|
my $self = shift; |
33 |
|
|
|
34 |
|
|
$logger->debug( __PACKAGE__ . "->buildMetadata"); |
35 |
|
|
|
36 |
|
|
# decompose identifiers for each partner |
37 |
|
|
foreach ('source', 'target') { |
38 |
|
|
|
39 |
|
|
# get/set metadata for further processing |
40 |
|
|
|
41 |
|
|
# Partner and Node (e.g.: "L:Country" or "R:countries.csv") |
42 |
|
|
if (my $item = $self->{args}->{$_}) { |
43 |
|
|
my @item = split(':', $item); |
44 |
|
|
$self->{meta}->{$_}->{dbkey} = $item[0]; |
45 |
|
|
$self->{meta}->{$_}->{node} = $item[1]; |
46 |
|
|
} |
47 |
|
|
|
48 |
|
|
# Filter |
49 |
|
|
if (my $item_filter = $self->{args}->{$_ . '_filter'}) { |
50 |
|
|
$self->{meta}->{$_}->{filter} = $item_filter; |
51 |
|
|
} |
52 |
|
|
|
53 |
|
|
# IdentProvider |
54 |
|
|
if (my $item_ident = $self->{args}->{$_ . '_ident'}) { |
55 |
|
|
my @item_ident = split(':', $item_ident); |
56 |
|
|
$self->{meta}->{$_}->{IdentProvider} = { method => $item_ident[0], arg => $item_ident[1] }; |
57 |
|
|
} |
58 |
|
|
|
59 |
|
|
print Dumper($self); |
60 |
|
|
exit; |
61 |
|
|
|
62 |
|
|
# TODO: ChecksumProvider |
63 |
|
|
|
64 |
|
|
# exclude properties/subnodes |
65 |
|
|
if (my $item_exclude = $self->{args}->{$_ . '_exclude'}) { |
66 |
|
|
$self->{meta}->{$_}->{subnodes_exclude} = $item_exclude; |
67 |
|
|
} |
68 |
|
|
|
69 |
|
|
# TypeProvider |
70 |
|
|
if (my $item_type = $self->{args}->{$_ . '_type'}) { |
71 |
|
|
my @item_type = split(':', $item_type); |
72 |
|
|
$self->{meta}->{$_}->{TypeProvider} = { method => $item_type[0], arg => $item_type[1] }; |
73 |
|
|
} |
74 |
|
|
|
75 |
|
|
# Callbacks - writers (will be triggered _before_ writing to target) |
76 |
|
|
if (my $item_writers = $self->{args}->{$_ . '_callbacks_write'}) { |
77 |
|
|
my $descent = $_; # this is important since the following code inside the map wants to use its own context variables |
78 |
|
|
map { $self->{meta}->{$descent}->{Callback}->{write}->{$_}++; } @$item_writers; |
79 |
|
|
} |
80 |
|
|
|
81 |
|
|
# Callbacks - readers (will be triggered _after_ reading from source) |
82 |
|
|
if (my $item_readers = $self->{args}->{$_ . '_callbacks_read'}) { |
83 |
|
|
my $descent = $_; |
84 |
|
|
map { $self->{meta}->{$descent}->{Callback}->{read}->{$_}++; } @$item_readers; |
85 |
|
|
} |
86 |
|
|
|
87 |
|
|
# resolve storage objects |
88 |
|
|
#$self->{$_} = $self->{container}->{storage}->{$self->{meta}->{$_}->{dbkey}}; |
89 |
|
|
# relink references to metainfo |
90 |
|
|
$self->{meta}->{$_}->{storage} = $self->{container}->{storage}->{$self->{meta}->{$_}->{dbkey}}; |
91 |
|
|
#print "iiiiisprov: ", Dumper($self->{meta}->{$_}->{storage}), "\n"; |
92 |
|
|
} |
93 |
|
|
|
94 |
|
|
} |
95 |
|
|
|
96 |
|
|
|
97 |
|
|
sub buildFieldmapping { |
98 |
|
|
my $self = shift; |
99 |
|
|
|
100 |
|
|
#print Dumper($self); |
101 |
|
|
#exit; |
102 |
|
|
|
103 |
|
|
$logger->debug( __PACKAGE__ . "->buildFieldmapping"); |
104 |
|
|
|
105 |
|
|
# build mapping |
106 |
|
|
# incoming: and Array of node map entries (Array or Hash) - e.g. |
107 |
|
|
# [ 'source:item_name' => 'target:class_val' ] |
108 |
|
|
# { source => 'event->startDateTime', target => 'begindate' } |
109 |
|
|
#foreach (@{$self->{args}->{mapping}}) { |
110 |
|
|
foreach (@{$self->{options}->{details}}) { |
111 |
|
|
if (ref $_ eq 'ARRAY') { |
112 |
|
|
my @entry1 = split(':', $_->[0]); |
113 |
|
|
my @entry2 = split(':', $_->[1]); |
114 |
|
|
my $descent = []; |
115 |
|
|
my $node = []; |
116 |
|
|
$descent->[0] = $entry1[0]; |
117 |
|
|
$descent->[1] = $entry2[0]; |
118 |
|
|
$node->[0] = $entry1[1]; |
119 |
|
|
$node->[1] = $entry2[1]; |
120 |
|
|
push @{$self->{meta}->{$descent->[0]}->{childnodes}}, $node->[0]; |
121 |
|
|
push @{$self->{meta}->{$descent->[1]}->{childnodes}}, $node->[1]; |
122 |
|
|
} elsif (ref $_ eq 'HASH') { |
123 |
|
|
foreach my $entry_key (keys %$_) { |
124 |
|
|
my $entry_val = $_->{$entry_key}; |
125 |
|
|
push @{$self->{meta}->{$entry_key}->{childnodes}}, $entry_val; |
126 |
|
|
} |
127 |
|
|
} |
128 |
|
|
|
129 |
|
|
} |
130 |
|
|
|
131 |
|
|
#print Dumper($self); |
132 |
|
|
#exit; |
133 |
|
|
|
134 |
|
|
return 1; |
135 |
|
|
|
136 |
|
|
} |
137 |
|
|
|
138 |
|
|
|
139 |
|
|
1; |