From 6a0e0b3ed61eeda4af083b7640ef7f11d730e715 Mon Sep 17 00:00:00 2001
From: Willian Agostini <willian.agostini@gmail.com>
Date: Thu, 2 May 2024 00:12:47 -0300
Subject: [PATCH 1/4] feat: method for insertMany itens on postgres

---
 package-lock.json      |  9 +++++++++
 package.json           |  3 ++-
 src/background-task.js | 16 +++++++---------
 src/db.js              | 10 ++++++++++
 4 files changed, 28 insertions(+), 10 deletions(-)

diff --git a/package-lock.json b/package-lock.json
index 8ad697b..e61eb40 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -13,6 +13,7 @@
         "draftlog": "^1.0.13",
         "mongodb": "^6.5.0",
         "pg": "^8.11.5",
+        "pg-format": "^1.0.4",
         "sqlite3": "^5.1.7"
       },
       "devDependencies": {
@@ -1066,6 +1067,14 @@
       "resolved": "https://registry.npmjs.org/pg-connection-string/-/pg-connection-string-2.6.4.tgz",
       "integrity": "sha512-v+Z7W/0EO707aNMaAEfiGnGL9sxxumwLl2fJvCQtMn9Fxsg+lPpPkdcyBSv/KFgpGdYkMfn+EI1Or2EHjpgLCA=="
     },
+    "node_modules/pg-format": {
+      "version": "1.0.4",
+      "resolved": "https://registry.npmjs.org/pg-format/-/pg-format-1.0.4.tgz",
+      "integrity": "sha512-YyKEF78pEA6wwTAqOUaHIN/rWpfzzIuMh9KdAhc3rSLQ/7zkRFcCgYBAEGatDstLyZw4g0s9SNICmaTGnBVeyw==",
+      "engines": {
+        "node": ">=4.0"
+      }
+    },
     "node_modules/pg-int8": {
       "version": "1.0.1",
       "resolved": "https://registry.npmjs.org/pg-int8/-/pg-int8-1.0.1.tgz",
diff --git a/package.json b/package.json
index f07edea..7fac7e4 100644
--- a/package.json
+++ b/package.json
@@ -24,6 +24,7 @@
     "draftlog": "^1.0.13",
     "mongodb": "^6.5.0",
     "pg": "^8.11.5",
+    "pg-format": "^1.0.4",
     "sqlite3": "^5.1.7"
   }
-}
\ No newline at end of file
+}
diff --git a/src/background-task.js b/src/background-task.js
index 0069dd1..8387b74 100644
--- a/src/background-task.js
+++ b/src/background-task.js
@@ -5,13 +5,11 @@ const db = await getPostgresConnection()
 
 process.on('message', (items) => {
     // console.log(` ${process.pid} received ${items.length} items`,);
-    for (const item of items) {
-        db.students.insert(item)
-            .then(() => {
-                process.send('item-done');
-            })
-            .catch((error) => {
-                console.error(error);
-            });
-    }
+    db.students.insertMany(items)
+        .then(() => {
+            process.send(items.length);
+        })
+        .catch((error) => {
+            console.error(error);
+        });
 });
diff --git a/src/db.js b/src/db.js
index aa37a0c..23f4073 100644
--- a/src/db.js
+++ b/src/db.js
@@ -1,5 +1,6 @@
 import { MongoClient } from 'mongodb';
 import pg from 'pg';
+import format from 'pg-format';
 const { Client } = pg;
 // Connection URL for MongoDB
 
@@ -47,6 +48,15 @@ async function getPostgresConnection() {
 
                 await client.query(query, values);
 
+            },
+            async insertMany(persons) {
+                const query = format(
+                    'INSERT INTO students (name, email, age, registered_at) VALUES %L',
+                    persons.map((person) => [person.name, person.email, person.age, person.registered_at])
+                );
+
+                await client.query(query);
+
             },
             async list(limit = 100) {
                 const query = 'SELECT * FROM students LIMIT $1';

From 1ea85ab9d2280ac9f6801472d17b103ec2f76acc Mon Sep 17 00:00:00 2001
From: Willian Agostini <willian.agostini@gmail.com>
Date: Thu, 2 May 2024 00:23:23 -0300
Subject: [PATCH 2/4] feat: Added streaming for fetching and aggregating
 MongoDB data for batch insertion.

---
 src/cluster.js        |  1 -
 src/data-streaming.js | 12 ++++++++++++
 src/index.js          | 45 ++++++++++++++++++-------------------------
 src/stram-cache.js    | 33 +++++++++++++++++++++++++++++++
 4 files changed, 64 insertions(+), 27 deletions(-)
 create mode 100644 src/data-streaming.js
 create mode 100644 src/stram-cache.js

diff --git a/src/cluster.js b/src/cluster.js
index ade430e..6c01088 100644
--- a/src/cluster.js
+++ b/src/cluster.js
@@ -26,7 +26,6 @@ function initializeCluster({ backgroundTaskFile, clusterSize, onMessage }) {
         })
 
         child.on('message', (message) => {
-            if (message !== 'item-done') return
             onMessage(message)
         })
 
diff --git a/src/data-streaming.js b/src/data-streaming.js
new file mode 100644
index 0000000..a66455e
--- /dev/null
+++ b/src/data-streaming.js
@@ -0,0 +1,12 @@
+import { StreamCache } from './stram-cache.js'
+import { getMongoConnection } from './db.js'
+
+const ITEMS_PER_PAGE = 4000
+
+const mongoDB = await getMongoConnection()
+const stream = mongoDB.students.find().stream()
+const cache = new StreamCache(stream, ITEMS_PER_PAGE)
+
+cache.stream().on('data', (data) => {
+    process.send(JSON.parse(data));
+});
diff --git a/src/index.js b/src/index.js
index e954588..df80f6f 100644
--- a/src/index.js
+++ b/src/index.js
@@ -1,27 +1,16 @@
 import { initialize } from "./cluster.js"
 import { getMongoConnection, getPostgresConnection } from './db.js'
 import cliProgress from 'cli-progress'
-import { setTimeout } from 'node:timers/promises'
 const mongoDB = await getMongoConnection()
 const postgresDB = await getPostgresConnection()
-const ITEMS_PER_PAGE = 4000
-const CLUSTER_SIZE = 99
+// const ITEMS_PER_PAGE = 4000
+const CLUSTER_SIZE = 8
 const TASK_FILE = new URL('./background-task.js', import.meta.url).pathname
+const DATA_STREAMING_FILE = new URL('./data-streaming.js', import.meta.url).pathname
 
 // console.log(`there was ${await postgresDB.students.count()} items on Postgres, deleting all...`)
 await postgresDB.students.deleteAll()
 
-async function* getAllPagedData(itemsPerPage, page = 0) {
-
-    const data = mongoDB.students.find().skip(page).limit(itemsPerPage)
-    const items = await data.toArray()
-    if (!items.length) return
-
-    yield items
-
-    yield* getAllPagedData(itemsPerPage, page += itemsPerPage)
-}
-
 const total = await mongoDB.students.countDocuments()
 // console.log(`total items on DB: ${total}`)
 
@@ -37,25 +26,29 @@ const cp = initialize(
         backgroundTaskFile: TASK_FILE,
         clusterSize: CLUSTER_SIZE,
         amountToBeProcessed: total,
-        async onMessage(message) {
-            progress.increment()
+        async onMessage(cumulativeProcessed) {
+            totalProcessed += cumulativeProcessed;
+            progress.update(totalProcessed);
 
-            if (++totalProcessed !== total) return
+            if (totalProcessed !== total) return
             // console.log(`all ${amountToBeProcessed} processed! Exiting...`)
             progress.stop()
             cp.killAll()
 
-            const insertedOnSQLite = await postgresDB.students.count()
-            console.log(`total on MongoDB ${total} and total on PostGres ${insertedOnSQLite}`)
-            console.log(`are the same? ${total === insertedOnSQLite ? 'yes' : 'no'}`)
+            const insertedOnSQLPostGres = await postgresDB.students.count()
+            console.log(`total on MongoDB ${total} and total on PostGres ${insertedOnSQLPostGres}`)
+            console.log(`are the same? ${total === insertedOnSQLPostGres ? 'yes' : 'no'}`)
             process.exit()
-
         }
     }
 )
-await setTimeout(1000)
-
-for await (const data of getAllPagedData(ITEMS_PER_PAGE)) {
-    cp.sendToChild(data)
-}
 
+initialize(
+    {
+        backgroundTaskFile: DATA_STREAMING_FILE,
+        clusterSize: 1,
+        async onMessage(message) {
+            cp.sendToChild(message)
+        }
+    }
+)
diff --git a/src/stram-cache.js b/src/stram-cache.js
new file mode 100644
index 0000000..027a089
--- /dev/null
+++ b/src/stram-cache.js
@@ -0,0 +1,33 @@
+import { Readable } from 'stream';
+
+export class StreamCache {
+    constructor(inputStream, cacheThreshold = 4000) {
+        this.cacheStream = new Readable({
+            read() { }
+        });
+        this.cache = [];
+        this.cacheThreshold = cacheThreshold;
+        inputStream.on('data', this._addDataToCache);
+        inputStream.on('end', () => {
+            this._emitCache();
+            this.cacheStream.emit('end');
+        });
+    }
+
+    _addDataToCache = (data) => {
+        this.cache.push(data);
+        if (this.cache.length >= this.cacheThreshold) {
+            this._emitCache();
+        }
+    }
+
+    _emitCache() {
+        if (!this.cache.length) return
+        this.cacheStream.push(JSON.stringify(this.cache));
+        this.cache = [];
+    }
+
+    stream() {
+        return this.cacheStream;
+    }
+}

From 1a90711c9b30272663b742753526934856dab0b0 Mon Sep 17 00:00:00 2001
From: Willian Agostini <willian.agostini@gmail.com>
Date: Fri, 3 May 2024 12:42:23 -0300
Subject: [PATCH 3/4] fix: changed CLUSTER_SIZE according to the number of cpus

---
 src/index.js | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/index.js b/src/index.js
index df80f6f..1ea7814 100644
--- a/src/index.js
+++ b/src/index.js
@@ -1,10 +1,12 @@
 import { initialize } from "./cluster.js"
 import { getMongoConnection, getPostgresConnection } from './db.js'
 import cliProgress from 'cli-progress'
+import os from 'os';
+
 const mongoDB = await getMongoConnection()
 const postgresDB = await getPostgresConnection()
 // const ITEMS_PER_PAGE = 4000
-const CLUSTER_SIZE = 8
+const CLUSTER_SIZE = os.cpus().length
 const TASK_FILE = new URL('./background-task.js', import.meta.url).pathname
 const DATA_STREAMING_FILE = new URL('./data-streaming.js', import.meta.url).pathname
 

From 644bb49e57088cd4a2f6577b0d2661d72b665fe7 Mon Sep 17 00:00:00 2001
From: Willian Agostini <willian.agostini@gmail.com>
Date: Fri, 3 May 2024 12:57:35 -0300
Subject: [PATCH 4/4] docs: add image for benchmarking

---
 README.md               |   2 +-
 assets/benchmarking.png | Bin 0 -> 12208 bytes
 2 files changed, 1 insertion(+), 1 deletion(-)
 create mode 100644 assets/benchmarking.png

diff --git a/README.md b/README.md
index fbe0ed7..1d8f26b 100644
--- a/README.md
+++ b/README.md
@@ -3,7 +3,7 @@
 Example of [how to Migrate 1M items from MongoDB to Postgres in just a few minutes](https://youtu.be/EnK8-x8L9TY) using Node.js child process
 
 **First leave your star in the repo 🌟**
-![Aumentando em 999x a velocidade de processamento de dados com Node](https://github.com/ErickWendel/parallelizing-nodejs-ops/assets/8060102/6974de93-7848-477a-9198-9d99dedc18f3)
+![Aumentando em 999x a velocidade de processamento de dados com Node](./assets/benchmarking.png)
 
 
 ## Running
diff --git a/assets/benchmarking.png b/assets/benchmarking.png
new file mode 100644
index 0000000000000000000000000000000000000000..1e0d9b201c80f71ded7018593f74082ac65d189c
GIT binary patch
literal 12208
zcmbuFWmuH$+V2TT=@5_-k?!skM5P6!JEeQ*6ci*>N<bJwx<NVyq=liohVB7|9vEN`
zKF@oswV$;<?Bm@ZX6BxI=02{z&j0!QUr`!rO8B^saZylE@L#=Dc!Pq1mWI3rU}GZR
zb6+h-BR_ClU+R0Hpb&K3zfhAn2&hp|o}j!^kkj@tfiAk(QSY=Z!w+X0*(uj4NbueW
zB<gcglIaO@3IjCF%8WmoYmz!TTaL$y$}z{vTa5SQhd*8$S$a=-$oI~1K@^9}z4GYE
zSl7CRrNO>MP52;_1x0%6M5P|*%l(Gstg!4Z+J})O{=;pb9S5Shk}R9oo`DD-torT3
zwc?9Qfxv>@BAEbKH$|`_Hp6=&`H#xyra~@6^7mg>`Cn$SA@5-`l)rzF_Sdb~|La=;
z!l5>fZsD=9oxz{*ino+qdYyx6@7OBd(h++L70h^yBBmo5`zF$LpM}M3CQi}F_2`<w
zBoAEFh><0C37v?5sik#_stkXiDCx#@1O3tx=JV?<ML;@yyo2cMlbdAz+-Y~Yx?uBU
zyqK?(-`$}YmRbteei|8ONyk>Y!7H<GVXUnHtK^l>^c5DG>{j|FFRRPu@3MH(AhYDm
z;xtTSmS5lp(*0}s#so?{S{&$hmV|mDX{0<IIw?HJ&RB57N^6A?i&wMp!(V%hDdo*=
z`qvx#NkEUO4LxF<gj{M5bKo)<MOc>L^zzo_OXU}>`pH2?PjpL{k1qt$d<GNGXa(l2
zn=C%5ER<H(396RwKcxYhSrq?1zp?VrENHR|QnyO(ZunqPC)+P>DSDgJV$y<Z2cG8{
z_*VtGr6OP-cs|-yyt=K9d+WTEn}ov1L+WWY<@z2I+vmGRe@)VNmedk_Dbc2<F-y>b
zUPzQ-74JidQYH$$N%k{DO~4KYD{MZ2sTiG90nK^FbgksNUl`7#bg@j<iH@pWFK=yX
zDIlh9KW(D)puhxnWTSM$5}Q}S(l00orVs8{M_*dQN3k0Wmg;|-XMBq+yjSzBE`#LD
z_}!jYQ5mOb0(<Z|?je-$C}K?X4Av=WiINh^714tUr%iXK97~A}^p!9AIZBN7VsBHD
z`^fgJo13CkyLKLWuKs*&m&&O(qUSMi3yp>$wiv|suG7*J7EDB`-aJsUiHbmYdbfw_
z=QO}$`V(&|*Y?lrWrDL6Z*E1aLV6Z{ytwFkx@N3aNY-E4#zaXQ27MODkQ8u5Pz2>~
z@T2lXA0k>?9N^rqyAEh@4Pq4N7oln=-qf_K6q`-1iI?da|3DmYKtQ&902FC>*iLW~
zECPOe7B+nsHdz;dTnY4%P+2XA$#RGAX^$<{otS(Ol**&z9MsjJYS%uDxBz_PEB5g#
z_@?@dHCD>Z_=A1-kI$-K^yhLtmp6Mx9;`))Mo2u|e=C$3=>N%f2!-)eJa%kPKPc#z
zZi26Nt#^&Z9zs>sm(aLMk?uV8#}<91e&se^?AMow5HaC*4r$yXC;0U!x~|`Wq+nF0
z^#q7}iTM%R@isYMwc})Xzc;)?*;KHPM<%XHqjVXU`BIGUwId)Vk)U-=OF>F(69jxw
z;)4?#=TT2u4etJ4<OT2O!p${)tUP`(!<X?O2Zx!CMfB1+63VX-<kJ_z(L1&-C_$bS
zI{M%_ZSPq<6k-v5UH?YZ*jRz?woBG>97XAnY>lCBFqW^(P_$KA`#k+z+_3q)ULx3V
z@{rI=3p}*)QTmw`GyJ?4w~B(1)$egEWy90U1#yWp&{7!S(B0A{)w7qE0Z8F}wicPW
znFFV0%Mx^{$)1EIsKeH;@uGQtJN{DgKE|OU%?i^52^*S%oXUe+7ycTHo<@4iIW;wR
z7k<SemX4CGwFkp6jo-I6X=PU~L6-iJj{QoemC~xV>w3fMeS6lwH=Z_nM&^uvsNl;l
zw$s+sIQ7ckV|>?SLJzA>xC;~u!&8*pNAUOVma8>7W|gVeyt~|a=$m%oT;yo*v$<IV
z3S`<G*Gn4~WT_oA^=tm^SM?}08BlGP99=PhT8?dcF3Vlp<vp6^XjeL1k)5G4LS>L7
zL-gLrJ+rJuZkDyW^)yDc<U_VJVZ#;9HJ5vlUsId1z3-<n^Ny`;$m>R*o|__E+(%92
zmXw%^T)lOR<`>@33J2fYx<bg-p6oEk=_UD3Fbz44C#y~=I%)3edjdi=_HWFhXpCLW
zUSs`uP48At8}>HpT}KfqtNUwMtkjq<iozly-aV#_3^f<T+nH|+GBmn#8laHJhRMy)
zjXF+{5|C<lj2wR}2-*Sm<T!q(xf;j+cqth|koly_CvgOy(Am~WMN#whenuavS@vND
z|5tm7JO88NLR#8O=C?iqqm{;*h5Np!)X&p|#hNUh<<Pl%sP8hq^VX;AjwEg=j?lp<
zK=Wxn$~vhVIWkZBw6DAD%1_rsW$LQ}(KNDvo%c@<(x{fyvw~{g1_?tnf^--wp7#~V
z7erHM7+Ky#NO^J?UEeXCx_J4gt%J9^Oj~~NH23UzMlO<e>T|_a7+)8S9Uz=^K;yn4
z`fjTloTa!~K5i0R=j_XG<My;^f+CgVzwKaI#jr23ICI(|_hp`(N!Yx_^_A4x6|x)L
zxH33K@Ott;Dxzgszf>LiBGF4)CS=QFE%5E-h_3!-KY;3Z!yal<WvUL+9ps15MoXyQ
zURWf}d{1XK7S*pGB?~b6$k^`sG|bW=En@M4DpqXmMAU)%v@3hRS`tp{fKRUpJG%YN
z2$lh=pA>knZYgg=1{VUWja%_v<UTXO(=@vM(tp;eQ~;$hm9PbZT)l6S^Oh9~%tUeE
zQVo)eg{(e0GIRw5`En6Y76D2)+5!PJCh5E0%^BLSZM3)w8tiVB-KSvlZkc-*Kle<L
z@$t;ce^-*fS$?n}Arp~&El_lU%}=g<w~|XE6hs~qh8kyrCY?~fb2gWP7qZ)V{^L~f
zq+V-mluN|qLN4(2!6n3cmyVXjNPi>f_!2c;xyrOlb|bQaLBrkeNElq4eD<_^6(%#k
zyMcwk-;h8%8`k|0NK48iUCXez_go4ugr_Q)quc3?zy+0Z$`K(xk=;v)lgqhUdOP1+
zVbQXnP7RG_GmebVY{eitUcIz&Y!!taJ%9Wpyofg}BF_oxlE-SpzRUSd;5K=ChIh;&
z135{CH-d$Y6&!qNw0q|N8jjQe(v<U|Ha5q?7X@05(}$z}^ao}!diBu*d1JKxultP6
z1PY$ls`Pu3Vq<9<b4%XxuH~AysG3p|*ovshx=E-r&kPbSyRwI%7p$F*7HN%_h?&@W
zBC2|0-lG@N5!&mDtaMPW<R_V_fg$Z1Z#7((9mO$qc{>ye<(ZSZ*I*NOt^Vly`fx*b
z+nI?cl+=0k1K|T}Ec}o2wi0iBc{cDWY94i5J}?JirIdVH^7$^UXz4T_ax6{-ma`L8
zb4hua!qUEMN3T>5$;b^JUd1^dr$5d0Gis0w@<W*Ls`@K0{&WalOx@xs+ncU_ywrwG
z&ea`04{^Pg`)b79KLd4%e}UjP^w+~8KU&Bdpts^BX0dB!%FRH8577q?m839wie#8j
zfP*#5;_g0bw#zb2m^P~!+uwB7`rc&v-q4Ge{0U@(jrl`7Jr=fJ4*{OZG7wkGB*D7P
z%_8veyB{h12ww4_PdwxV=R*8N&l*RsYPvInGTRykVmo;<vw^de)x07=SAX;Rz@R5}
zm(i%TYj!_#Pqsj|ed1Z4Q*Ag?UD8cdV)>kyKPndJog$<4E4I62?VG9{Z}{3Ugm=Uj
z0Tx57>PA-0n5M4>@ehMTiJUPaZSDp~Moq3;+5o^rwRD71`tVO7k#GsVU)$=z`REC)
zU``kCmDJZ1Gr)@BCQ=AU`*kP;`ev=izpC54NOcAeXQ{>TUX6oFxGEA&nAf5`L<{H2
zgXi5ZvGED{_PujmWs546-K7^>rc>u?L1%E~fh&$iu`zUxmH=&r)WOf=9HK_X5BwJP
zouO!171CxyQpy3R#OSnU2iE#&YGY(9Q?1t&zZ6e$391_?70cqWF@yY`zsH?r0XTBS
zPwZaCYuCLT!lI<7vxN;1h|X9#9itXmr0>;3&rAU}@ZM&mlD-VQS^31%cIj}^GeBXs
zzQHIyUY{yyRG}1Lwir|KOe1-}G}pIP!3ILar3$Kv+nj9teo`-T`!V}7{bX5){?j{Q
z@Olk&bMaoEtM?p==CGBM$4Bo9_RpINFVDG(cN7N%5WaV0DVVL}yW&LtD}epk2tq|+
z)oo_hs=&;`>vH=O;R=VfuWSD>t#OiUd%S+}GM++IA^Gu+{0aBHvTv}tf8txAf)YKc
zNAu2d$W1^pJauDpv7DtA*rAXZ(u_`UK04+>zvu}<W&|*?tBiwDvOhTika~WA8s|QF
zz;>e}vBUk7MsP5M=Kske8c66}vUaff&o;@UmYG1S>*!k7z+?Lj;uU}?uBSA8aqvHs
zzU}53zMzczic*D-?`vKg9Xz}mg$>KV!ltxNPAba0c$W<2`x1<}k)@vXC~f!U_pL+j
zz^pk#<k>uCUyXwR#LAWqaaCoTW%MZ%;Z>We_qDvln<WtZ<d3^XXi79{l7O(Lg>KW1
zct4=@6^pBG!d;Q`(-u*Cz5j#ao4yP|-7m%(h37#nX8_d-ZmutEQy<Qa7Q2{NPcg*Z
z448hZJmR#Yx!j}sZsGGJWcO|1zJnw4)+^|oi=C@gvR<FMEf&o;rs(wHZz}I5=41v^
zOhQONQu;aKymHT$BX5M-ib0MG<J7jEtnW>|#zSA3ZwXln?8WM!WSuJ>QPh2N^uh9Q
z-6bb<@tz1C)4THfI;g4Ql6%KJCi9naT+eR=mV&0L96omgF-Nuz_)=<My^6XqTQY>B
z`gfxX-vhSDzt~<>+;_jUVqL+|85DzVp$+VC!n`IU!@@^tx0Hv^6FB-LB9G5G_=Ftr
zD0+dCjwyfYO?VXf3v}k49e)ID>DfRN@N(@z>zO|}ql~0gyOx#jF#&*%Q?r3MdyAJF
z9ht{S(rEMz$t(}iAM&MywsjGn`o~?o>mHTp_Q7`duv}>Li0^MC13?d_wf+cSLsRu*
z!+upe!MLk)9Mi?7?wP?ogWGoO8kzTQ2V4RtH-G>U<RYkN`07YR;NR!slsS`}4v#df
zcZT({q<<?I60bi1Jv>uaWNfU&`9k~xt=3;0izP?2=Hxs~CFEYCI>XNBL6*LUi|BTX
zpg*Hdh8%T5Cl;1Qk<^@tgyqQ-x3DcAyS!8Hq%#XHSGGf|QBHEx6m%nE%&^bOLp4bv
ztkjBiDVbI8&Uh!bP<3U@L5kcu>eGN%TrQg8oHN8$tgGf*DPnH{Ucar;odVNTJJn75
zY<@(Ag+-L_QAWyX4pc2lIvS1^=45T}sZ1-8c(vB4s|RCWn51D1*NsFgMjOPbY%Y$9
zE1A9jEHUgdJFa9fkl)>GZUCOW0l;pH?1%OGWFdX5H!wxajC9Ut07B);vNznBZox&d
zx8%q+b+L4xPx$6$x_-;TjZE&96e<*rjnH(Y>?k(S({W{&wWXl*tcFMaDt_!sD=$qh
zuCuVcj*GwZm!<;gDnhs0MXG+KN39uakg@xlwA;=2H0_=X_NNa=fqY(>ddE)h;5GNW
z!?MjjY^9bhHo?&HzsMZ03GGu&Tx6<qA|Ru4m<&!Cmw~SbPCbIS0<yYX5?=lEsE0Y8
zU+dme17NfVMq0-VS=CFFpLj+6V(wSI=n*Fe!Ea7pLZX0WB<UXGKOVAN@W-6XZD#+c
zC;}9K%Eq_q<~`0ycIswQXWyw+6?xqW)$cCctl_PCamZphr;s)*5Gys`aQxX1!=Xhd
zefzk4KsCQ(!-L@;ON@Pv=Ae(EuiGJ&o4Jf3rWm<doo#VZ6u`O92WQ#rXLl){o&&Md
zfg$FUEVmiDc@3)eo6?p$B)8e9`%6&<?4k2p4od-H95YJogH>6^7Lbm-Gxftu*2O&Q
zAR~671_`;D17obMqqe^)5FZbf6%g=EzaD3++q=LvDRz&X*8gM{5LO8ZADC2hkyHcb
zRMowc_05Rcd?H9wP(KhcKx*dtlkm{|);?~UiZ*zkk8uU1xHo)mQq_m|MZ;~SibSTF
z%#EB(ac{)HT0!q2#`q7nuL~>tJvgk+ww+UHi)A!PvWc@kJfYm=lk`t0aWZFE$Z*Wo
z`C00OJQ~T#XhhYE)>KkPWXg{i4=_E)9+vFe<iC0p(8cof0}~Cb7kIL}fxWn8gter0
zcfVb)j=Pr^os|4+KH@q-?tJvEW;tywn#aA*49{lg%ivTKQN%BTuK@Sy{Ejt$x#)r4
zt%ZHeI{`UP@$Q^@bOM#v@cJLsN;*F`kBA@BS<FCRtc1KVPgxIWO5WVr+WFMHAWFkP
zbCnv)@X+G~r=G%|a8TRb10gE&Yq3L<4&O7x`pxeOH!|Jg@KZRh<Iv6-K1(+cWS(_W
ziAEU&<LK1euTXtsDpi#C@GPF?m%>7P=3~p&rIs?dDfX@8Z%0ti`brODFZ5@b&R@+*
zIQ@W(wyPCj>WGGqef!ioc{_lqKhdgd3%Pn4iM+)!%yiP|RY~p_)Yj&lO2(&n!zatV
zoI0+UISLcFaL;UCiu))NfDDUd6b0u3-#(JK0@^#I4gBI77no%9kwi%TV|?5~?*9O?
ze_j3mqq6@sWBY%55TSa4=>``T7ETkvVd%15nJO~`rz00GG1cD@T~{7W^}hAkZcNDL
z-*2Quf8Saq5e?I7NsAS9dGsq;{S5KtLnycY;RJP1LlKIG!F8rf0z6*|IiUpBsH|Ya
zotG#h_W?{L?;TM1yRmsrr{+_sN2!Mg37nZKhqS5IqU*gSdWpFD$rN85_a^IhjK8pv
zj8c2*G0*MNcu>(!$Yl;)={JjXo{P=H+sbz@%a#3dk8*Vt&UQ#4@xXDIX@vL9mWDr7
z93k;(iH`(XX$DhU+R*ofo#?)go8-JT>J46d$q!QHu~E%R`MviZnW~ppxd^e;ZAA?p
z9~ZDn*U0W9B9PRD*;(HEUD{zm%8cgKw{MS~fd|<9WM^N~Tfk5j2~Wk`2efKoqu9S~
zt^g1DEA}tTUtQspV+W!p>~F#@)@;2Hx>?3|+2<#hJFKW43G1g9$k_LxD$nu6M7PH#
ziwdduaHBfp@*nB?obBRQm<*8+`aK>KnVFd}vs`0h>~LPK;b@tiSq7h6YO*2um`R&o
zXHU9rOMtlAj{&#DNP+g{+^rVBnvQhc;nc@?q`|k*3M1yth=UHcM@U9$vxd(xOi#S$
zO`Af9BxSz0yZF@9E<Ux#-)HrfjdtqvLE|ngNCos!n?UXQk>hZm$}w0M!rz$KX{Yw!
zN}e5l3ViA0uzt}2#cW~dX?B3{+2(20R=Q@1(u$H{R8~%4hliq7=%z=$FCWpNg?PPk
z`SC}nycF_0-10=|W*gsO<UaRt_lV&tO&Fly!$V&br7AEoKzQJ$hcbtxkAwgh5+njn
zz`8M9^h7Gpwslbj??Kpq(E|=BVgF5n=v4v&q6=Au$1VU30_S*KMApcy;oy7&(EZ3)
zH0yIlaC?T#k|j5KU=;m!Menb;CAOaDpVO(=hBEwBhVm|*0C$yPbvwv;EX|8yFTyP3
zs(94s<^7W%rK1_pSXHkge%Q5jQm0}{Blz+zXN5Yr<I{T}g2#dNIq1-C6DK7gVESq6
zE75%hQ0;6><EDV<Er*xEomdkN2ItR~6xi%mX=&+^yW4J;?1E0O%oetwd9VODS+jYo
zeI}E^@OYF$J04K@H+h<N=v-|w!PI>p`egm<iQ@+T?-yU7dA5!QQg~;+?c^&1bbWcr
zGu)38@ng^6LO(ZUf`-{4|5bKuyH4oHb;wV9;dN#eZp@SeDbL3ukh)lcmhQVYud3^V
z7asw8KN6@s$A9g()vJos0r`CI4BKwbQ6F|^LIMSA%7mey^BsJeP-6K5Ns#q0Y;mp}
zv6p$9-KZn!EYflN<Z2ErAwlNr!cNxV%5%*4U-c!i!9&D$28po=;nhv3bP)3=fIfN1
zxSI3s{;%-3WS0iMy5cX>9cx-0hRP5Q!5=A~_JLOv8*Cf?IumgO&T6Gco8a`^V03AW
z`hs%`#e2F_{^9ad%3$2ZI8;pR$0E1!J<7-vMc~E1=N(r@0-Q%I^j&r-1QQ3~fRYve
z%kN1^TZ28};N}2c=v?sPI4atgbk^q7i^p8fy0>2HcV=WFYV7M@)%Cy|qi0VWC!RSp
z#cMP?dS~K=@E9r>g6cS@f}ekJY7v++1iauYNOt*~>7?2SKIlztytZogql$U)s)aJA
z0l}EC*Bjher+g2Lz~3;*!#p9hOd8-La1%kuJoLvK{`ms>H&|47WHY|=N)WlU!-K>q
zZf45EC3Eu&bWHp|^&=GXkMcC!AKa&LsmV2lPfOiAuVL5bBCV084lJ|^8{fgShqnH{
z+@fJj!!5qs&VPl1V5f{2cb0OhMiLmNWfyF1+EBls8`c{nj9J|2Z~#m+{>U|SZaF~5
z>lB4m=>NNVNpk@>rEnv6-^WE(tcl`{RPL3viRDfnm^+#r+Xh8}e#QX7u<FLwZJn{H
zJa5YF*YR0QDo*TxggM6775;u1e=D900XvsJojEdy77_hBwjCywiXttd9g_fUE=E>0
zl(`|C&tj3CJLNTCpN#<!3O3?;jOi-c?1mQIyz`6G)+eJDyN3n)TB^aw__Sy3l<l!Y
zI%cAPqdief?AZK9#|Dg)Dt2sKaLm^RK1ov{AbvYz`QjI<c05*XN&1ml%vB%nKlRVL
zD@mJi6EfuPvDMUm@X|mX#&1H%VUoIqO&Ri^W#t=-?>-ro4V^CWJ^dP`RTk^sut+{Q
z=0A91Qtb@|9qgcFzeHh75xas*&LttIjZEP#cPg0VcINqNt8rm5aOqO(X{KbVqZ98z
z@fz?iKg?<AvK;Ae(64}>@r7&3i!A6d#g?s0_J2qH8;X#IW=Ax_-_Jj6Rx<QMf{93k
zC;Ov3`MAlvXQ>u9PrWfIRbqH4w}1R$7@J_;$-MbN@~3sb2~Sx*;(M;0{0&GZ#su6k
zef)Y~;ax0yG;4}xY0p@Dy~|Xo@_zbLxxNIjix1!!N7^8_ACVFJ@j0>&hI`8l>*IpA
zkv2&Ibty!8D-62(<kKfjZ8G~3B7HsWKIuje!7|#IVG_b?n0H8HinXtKR9PfOjbR>u
z#f0C;@0VUN_7F;y!gsoQ^i!Rl&APbXcD=;kEv(H_T$qQcG>l=ez#~tu&)wZm(l6*L
zZx0mK3W5>B#yfCQe}z&W*#hdpUjz>QOmFuH5k_wj9?3|>pRqHq;+(Nn->K*+(DqeU
zzX@z~;7)LU@#LNZ&@?B?o-o3eLc@pxnzn|K3@TWcj(qZ+MH;>O=f4zG+>Po<Bq0+?
zeCH6e1O{nIr;=#^wkg{{_*%Vopx{EbQVXsDWorMNb_`OL4N2Y%a=+MlLnfXWf0WWh
zgdD|m*>MFXab)zKSH;5G->MlL<`g;fhB^%gC@yIk8lL_vSc)K8t+6aUDX20EWNOA$
zbpese2mEqe`dh+v!HppPg2){dxdkby{-*$1os-0yP(wPH43HIdjO4@EDnG=Vrwr0u
zaZj{BaatMIqElaz_Oy^szZ;^k6ZcCsppvDQu=Kj~=Kd@r<o$_kc{{r5QcK<A7;6Jt
z4Yt>ruIF;sB_c3i>$HgTmhQv$NOHqjHifCzd*9OwQkwHL>qjHi6{%`dbGSr7KRdcK
z>kYnL`+85M==aT-MtA*Ro@IVg266^c5x`;hGcb80;@LdDi(13M&h!#SInS~@yyD~x
z=P(n3m50{sz_vNXv&ZD{6Dm_Hq85OJ5M^bhn!j!JGlP51*{*}I-EVLi%74N0hgwZq
zR1fK8Qa){B6;GdDM0&ZRh&Ycy3vU7#w?BlVmnJj^iYE8Z!~GYo5BxKK2qlg@sK`7Q
zIgovKqQ1}!i1&x6o+uN9<>IW~Mj9I&DcJbJwa9?_S)RY;kdZsJ0cSSvT^rEELTSg+
z!u~S%)g7zR=@rrjEk8WNd4%PXa#<b}#AD5Vd8o!Wx#ze9yQ$rlQNJWcrqe46{@`Dy
z7XdO-O5!EP=})xEO&Pj$szh>j;$f%e4}i_+7!B83_y=f}od}3(jn17r&NRf@<oXlR
z<{5hfHBJ>imiRY=boX%8$V{iX1!H>1kskGhNnCDexxCM3y2;oC5{VrQn<=Nb?Nr6+
zXy7vb%;XbF4c1M31iq;xMKNf__$az|cxadXg=n0Fmt?J<H(ZGPxe`y9$zV-Ml1~%m
zhUVd;@%c09a?0%{g6-|A$0Ce4+VSYe&|EB}3(43RZis?H`1bxRfC!a+Zb5d(rqv%w
zM*C*o+VzZo8}mC-lBMX+l$l(gdK&;i!qTR?B2`hMfuU;O-{Np3U_6|gjw#!FXz-n0
z__$uWZNSaudjAwiJ4w>rdD2`sI(iam7f)XY2z`4t{U0{!RNLJ)v-m=I<GB>!*Ip=?
z9zP!w3B>-BSTzA3Wcj;BuY{r$8)jEmRHc4rsWtT1<@;#|#0OrValCI3KSu)xM6*C_
zH3BqkNTsV2)cd}nkjGpJ(WsR2&gE4J2FBBlzj~5pw(1rZerPjO_XT9Y$7ZEvm3+=h
z+tA1-*x~b3ZDj~81?Hb)ef=B7<SIul2<{dWVS#~!@WWA>7R{DF_7@!T6K4iW9)uf<
z4$`3=NL4qRAkMC*xDA32FUd63<KTw{qwFT~xoZp1_l~Vs$s52&54ZQMewwdlqd0D*
zX=#QtAlCJ3iLElTG)xm4Lpj2R%W85b+sMNI-Ic@*-OFg3zkOgAd|P)L@P~dSS-x{m
z%ZUEnZWopvw>DhQL_MuLaMJnW_PiIs$2D)ecI6XX+f!cx`9r_>JuFrB9;sCjCfyhi
zL$7#<o-K2J7CR9pi?xL;t)>dJ_pLI@=eiwN0FNfE=ybeLYl)jb1Tycyu^b<9ia*bN
zMj~Str&{g&^Bu%DAb+}oXmxicQ=I4DjXk$ZKdk>MA}5!=j`Pcee6f^DV5~@COZl`u
zMis3_FMSB(J_NtGMtSX`tIsnvr@hplqtD(}er4n%5gl><HkWavGxmT^5>De=l6jGH
z*8DVJ7QJzTWL`16I=f056zMJ6ZC!(~dC{-nMxW2&gB4_9X^A|{fo~F1yw8b<8njk{
zdil7%=@9H7res(uOHi{JQGHm@8+bDgt#rH1yn&ySo*S;eIU81oFx9pw?ua@Va#iq9
zZz&BR%=Rvq(qqr%KHd5g8m~OKxy3c`9=5spH&@hKsxoxyX3N#r&5-Hz3hS{-OR=e~
zi_aXyHSn!qF)Qnp`1siu17n_W#y*X%&LJL;(u3W^0nE88!SqOA+vnDE<Co2QYfS|Y
z8KhbL8PlMi-Yaq}^P*QelYM(c$3-ErcHN}U9>tS1t#m+3Z&b@zna<O^{dt_`bul<&
zEIP4eCw~>ox3USdY6BqEB9ED-w(`HtuC!|b!<y`FmJDv|BO(zSPp`?hQK&b7itieV
zhH?@!w)!1t6A31kp8$Goi`3%3NFEk$QjvWCu6!Y~xk9DNeGM4zI`UF?DT2c1S5KhY
zZn+5#h=7Ow+ix!~w?5hV2L;eg+bV7IQD<MpzeS#{Al>vXA+pm2$^C~b+PSjiO(ses
zhB2cb)DEc7c^dUViEx*`YUCm<zqys&UJ0u$ihM~$&{6ju`Ef5ur_UMFPfHnN!_1A;
zvV3tcNpY^&2PEO#&)bYJl)fo}+Wad<CYzRdm>p7#g2JLQ(Lno&3}Y?NC2S{xr&4y<
zM4-SAb30x9)IDI8aEq$*!gqWXD+Dd(tnT6KFtF8OuV5k3kLv^0Q2R)iDF-cm=lX=#
z{VlgU!ZQ-V!<PYjX);5bK$&O$y?{xB3sZ+jSQ4+86CUgAp)88t*_qlLNY9p=VCHI)
z@I<n5-}SBgjpxo5@NwuxW5tuQKA#+6%h3{BbLBiqR9|AR5))Bva^(l}#@)U2IXtf&
zKe$51J^7D>zt1P&d>DCRN3%Q@StLgyDwbksmpZ(-wV!Th*x<CS4+5B7#`kJ@_)sQ$
zXA|1CJj>6GWozY~h5GkQ$5>KC8trb*5F!Ei@C>?^4>j_Knr*opFS=Z+(xvv=s-7Q;
z2>Hr0J<p!#2Y(JP%ky+f7kC+OAUFMbTBbGQQzqzIoY^G6{<*1tU?F%qimSlLbW2=D
ztv`5l&0)(3+8pv4YMuoM8}yhkWphqQYaG^VdLL{T(jKKPT6R|qr#()N9~l+A5KH<C
zRcZjg%G^$u23{{c|DSnWc!H7k0u?<;BbaD%<5%8Pf%O2Di7i(c4Chx6A-66?D@-&n
zx@XR&lc%%hSa%>%MI_YKskxWlCO|M?_YDI<0h*|*_z*G5tP_N((2nZOUTuM1ywT5F
z_efRzuqsWzW=W(q`7~G4kKnr32Ck+~VXqrvc86UPkLBv{YSSJ6Vns}<usC{d19^1h
zBdRF|*EBa#Ez5t3a|15d#)BQMj5UOm&OZ@oya(jgXX?!Q1R*MLCl+_uWC|>()&#N4
zs0WY4@4BrVU+%#CI|Rk}rh?zz>D0Y+NjkzG<`<e#ZihsGn(1qI&gDMTP_tw;q$e8{
zZ~A16!g}chNC>k0Bnyof-(y+6-_x0~hhY3{mM-^4io{NMCxvMMY<e@ctgv-0h7b$p
zE3s@AU)zuMW4A`2^=v~<JU$ug)z>0O3xpd~A~8gmYmR0T5gr(;!u|>188T)CEgG9y
z<-nYXOUT8TLX8*{w8U4A{ORs}jTX}qps=;;#4PXu3bhH?U^v*QNR>9C-^7bsCgaE@
zw{hnAe%ZZ5?mwh1G6gSgGrNx1b<tZY{8w(Uwh=qT2^noL^AD`rRY_}{Tno8e51Vq;
zn6m_UMK#8Ni$v}PIqUAq$2e<qO@{0Bq0!@~9haQ2N_rQpZ~jPzmONvxrvYy&s2{sR
z)WYCRXkE-NKGJZTCYf}9{BG3tJFcdj$IdNirVny;S$=VbLlkrx>9c_Y85Fu9o>|_%
z>KK<$vuMBq&d2^j&HKe&qI|-VEE869P55L4_(XUlc6dJ2f>vWph`%4>t+M$aW0*9w
z`L7(P7wR-P{KxRU&u1cU&NFrdKtT~ix?2mO`3>C2vmdXr1pg+Z)BQ+s*?qR6shPo?
z&nEZBCoC@jy<2)xUhq<qKq7sgOr?~7J`lzbkjF{54}Sf}QbZge9m<#g#i6_hl?>(h
zjY>%Ejl4F(`PUWB-+Dgjv+UnLMyWp=!Q(wX#;^I3FJk}afscfnYks>6qXQGaQRZgC
z6Anr4@CsWQyFU0Gm6(Vpq7R1k7`TV(K-bfa|0?QJJjckXAB^2-?%H358EX<Z&oND?
zEX3T4h?0^)S|~cmpTL*z^PgHV&WGmba{Ss}M7sPL4df4ND#v+q9wC7sr>P(6Ys9%#
z)NcEOFCo<D)0ewJBq2zm7m0;d=p6C8t;fbabHcf?Ds3EYDH%xFv2`GedT{F--i)%(
zdj}Y&Y2BTndUDSC*5A}KPnKIMc-46E&^XxmpAO{Yucfy)Ysh?KtAkzQwFtxHv-*|@
z%O|hnwO9mBq+XSIqm<3*4(0iHPmqkH2)utDSZE^a@=`QbW@td4z68MBFG%BjIZ7P~
zUb|qcFQzx3zjuEb6l#J;M@L~YA}*3(8IC(#^)q_-^#o68%kMV`-N1#YD^|z#%K;f`
z1aR-&n8V|8jrSv}GLv^+ao6KACxmx;%fQ<m&<MGq)#d;@^~v4C6Q1cy!pXb1`HNeu
zThRU^xOWZcZigN&bIYLo!h-})o*5=3bJNr_HwW61L2R)vZ@6IHvfR$!^>hZC`1kC8
z0&U&BxlQia4ko<&ymEKT!u?iec{{_x`Q-{^SZcE%NvQhnlAi4*uRU1s_TflVa7-}m
z)2qo~@ST8&+?8oS|IrADK}Mvb;?6x}8^l(5MHnmwxHbx=w%&%^MyQDQn%*{w)%FL^
zb>GOuk(AyZB3wR1AkoeeydDACdDaL*c+6kT)Be>r0@sA-RAN&CV#j`|?u{?GGqSf&
zS5AcYwf=SmE2fuX3-_#DA5ca6%)qVVCXF-PXJrk6HseR*6vu*Ou65PsW{K>2df)Ox
z%_%8+`msxk%lPY)dRh1O^QT8NU;r`hydVvY$`LQxPF_}fvAWvGl@8$>%T!-?gVcbf
zc7CBcZ+u*TCbIgA1?b)`aJ8V>x%%Xlx071BZ5{6AmAsOS1eyqrHlWX5C;hBmEa-mO
zd}KyC#jpoa-MR0beOx8TQONSTOvas&$G?PB3;gc+T>vRZORC*WIji=0OS`q?tfl6h
zgPm%vd>)!}gmMw6NlNv2(_@v#WGuya%}czqe3WRTb`Kbi+Z@taz1*&VZuH^ZmK|{J
zE^!t$VSW9=aYr~;rF~}MDLs^Bs`hm;cBn?k?vN3ehR*yn<oxnaBAzxwAc*x(aY7(`
zh#6vS08VfJSMZ<1^7Ym!;X(r{7s?0#fR4I6;iIfk6wk?0g00+Jy$S8EZ{HQx`~5a*
z0H1q(2q4pS0dn*`$og)s^@$jIl3?%_8_wnZ=rNiH^;y06U;SZoj;5-_g9_}Q@Ao?X
zP?J|oNT^}AaLCC-yXd~=MQ=t)k>RYPVUHepZftRrv?^Sb>ck(e?#m}AYZizK1?&UQ
zuuQ9#T1NAYURa9KF@Fw6dHm4-%<PQj4CsddOZ+)7VRk_Wwom=K!%Rew(`4j>Fz-?7
z^hrmP{yVB6Q;7c-)g}{~>#WFlHE_<R=T_c0*|fdClIjS$3J=nbf0)v%9uIkF<Al55
zeD}TI`I-iq&bF=kN{&>Hw*6L%q|N)#(Sc%TI6?1SuM<45hGd%z??oe8iB$#1l&OL!
zX}7vlaIvl*r)qy)*p}s*9UmU205rN$>fzrE_I!?L^lkA};}h!nnfl~WhQ;VSDi(7d
z!tl+kADsld;j=CD7{d6POKU8e{VHL2NMh{l{KM(Pe_Dc>Gx@=e4X)Swg$G}KAIbz4
z9nG)zH#^KvL5}|#^rf@^aqqed29WvG@5=tc`e7@<H-CJn-%AsXmsSs+qq0jFl34w5
xFMq$vf>UXRuPLBord~ZRxNj1X?#>-n4t~5o@AD@u$RqeDuN2i3%H_?%{ttaVRwDoa

literal 0
HcmV?d00001