Add destinations

Signed-off-by: Gabriel Indik <gabriel.indik@kaleido.io>

.vscode/launch.json

@@ -14,7 +14,9 @@
       ],
       "env": {
         "DATA_DIRECTORY": "${workspaceFolder}/data/member-a",
-        "LOG_LEVEL": "info"
+        "LOG_LEVEL": "info",
+        "REJECT_UNAUTHORIZED": "false",
+        "NODE_TLS_REJECT_UNAUTHORIZED": "0"
       },
       "args": [
         "|",
@@ -35,6 +37,8 @@
       "env": {
         "DATA_DIRECTORY": "${workspaceFolder}/data/member-b",
         "LOG_LEVEL": "info",
+        "REJECT_UNAUTHORIZED": "false",
+        "NODE_TLS_REJECT_UNAUTHORIZED": "0"
       },
       "args": [
         "|",

data/member-a/cert.pem

@@ -1,17 +1,17 @@
 -----BEGIN CERTIFICATE-----
-MIICxDCCAawCCQCwQ58VBeUg+TANBgkqhkiG9w0BAQsFADAkMRIwEAYDVQQDDAls
-b2NhbGhvc3QxDjAMBgNVBAoMBW9yZy1hMB4XDTIxMDUyMDAyMjUzN1oXDTIyMDUy
-MDAyMjUzN1owJDESMBAGA1UEAwwJbG9jYWxob3N0MQ4wDAYDVQQKDAVvcmctYTCC
-ASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAK/bZPBvaA+V6HoXNP+oOQaK
-DPuLgFO3R7TTIBTCJttELv1lbfuw95Up+/5b4dPnnIF3wwE2GZsiMWJV7RgfDAUi
-x7saJJIIa2E8gLrmoaG99w+PYQW41OBz0p54tw4abN5RNsgineu1N5pIJOMJ6cMs
-D8IYfWSHDjZZvu3F2YCItSVYZlfmGBCcFCf4HASF6m4lUTZCDRBurjOQrwW9mXJv
-hkIa1HEa4l7Nq09d8Bokvieq1vHJUB78kYTR027z+sm4H2o4pXjzBOaV/z2yB7+t
-yqWbMjm8aq2m/gmpZTjDBPgX9XLMYHWBZWCpk1iHo/eqw+UeZ6kRZ0RR78Co+IsC
-AwEAATANBgkqhkiG9w0BAQsFAAOCAQEAH6rQx8khtfzH93YCstHduvEzUCHSyifF
-sDyRLvSmS0qHz1liLJyvWbT9xDQCpDZrxhQKJLN2eZxxlNaH6XBEfHQgi2I43hxu
-sd2KZ4wOWOk/HyM9BcibKNMtfHJdgQ5EYRc6OWDY1c8bQQfRJUBzrSJKldqfQjqC
-mPEeHXDH++yTg2Vfm7GZiogxqSWn/+ILzHNeWrvr0HJ86Guyg/NPKBxs0uasvgI7
-KqW+fcZ/9Vg6a4e+zRTL8EwYBX6dTSwgt4X9wuwMvt/K0qodgW6I4paqEpVJOS+d
-Z6WevHgHwZTr+mS3mJ6Y6u/DBD8/06uPAf3T5d/dC6Xtl4sEFkpNAA==
+MIICxDCCAawCCQCcNT0mrc6OBDANBgkqhkiG9w0BAQsFADAkMRIwEAYDVQQDDAls
+b2NhbGhvc3QxDjAMBgNVBAoMBW9yZy1hMB4XDTIyMDcxOTIxMDExNVoXDTMyMDcx
+NjIxMDExNVowJDESMBAGA1UEAwwJbG9jYWxob3N0MQ4wDAYDVQQKDAVvcmctYTCC
+ASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAM+68pQ5QQdpeDDi1DxOCnKV
+hJDN6KGWP7ai8JOvJFDiNHQWtK/I3Q+bH8FqaFOGS9ahB/d7aR+zAM2r5ENIm6uR
+CaUj5rTqNhQ8WKFGwdRgGyB3BsZseS3IzBl41FGb/DptC+BrSA8PEXzYCVCXzmnA
+zFP5U0TEw+Gt9Qyt+7JAZZ3y922vI7NpK8zdQeY600PXF0sDdzeK0OXNgfzgu69G
+AO8GTNalA30bR1n4OZ0/cbh5GkWJW2QziGaOm6KPZSQjIUQLoTY6ca48j2jf+5TS
+2sspU3gapk4yEvV+wd39nMoKUswP4OOOQj4NZnMMQ/wahCSInVCRNzGUEYK3XV8C
+AwEAATANBgkqhkiG9w0BAQsFAAOCAQEArD6xTglyqb405AfTJ/tvD3kse5FbqyKh
+se3Q5TsjFBu6PSmdkwX0oA6T2j34PbLbNmIbfwoC/rAKLJyr3sYEN3yCB1V1RWY1
+AkSYl7XTfD4KvGJja0Vk+PoQeMTp5P7vhSI9YQzVB9XgY12wl1PpUe3Lm4p2NEIZ
+dcYndhugqTp7JCUVMNWbIqODEHvdKINOlyMY2AwNYno+/Y11m3PENr4E8OKa1X0k
+xf1BNlj1w99hNhABstjHu1Q0F8V6/7GBjV69Ypukg0kmv1kYEJlqF9S5EZhIf0Rf
+AEVC/fR3lf2zpfL2JGLy97B5dpReC+1crZmlfAnBXz6c48RCe6YaHQ==
 -----END CERTIFICATE-----

data/member-a/config.json

@@ -12,7 +12,7 @@
   "peers": [
     {
       "id": "org-b",
-      "endpoint": "https://localhost:4001"
+      "endpoint": "https://0.0.0.0:4001"
     }
   ]
 }

data/member-a/key.pem

@@ -1,28 +1,28 @@
 -----BEGIN PRIVATE KEY-----
-MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCv22Twb2gPleh6
-FzT/qDkGigz7i4BTt0e00yAUwibbRC79ZW37sPeVKfv+W+HT55yBd8MBNhmbIjFi
-Ve0YHwwFIse7GiSSCGthPIC65qGhvfcPj2EFuNTgc9KeeLcOGmzeUTbIIp3rtTea
-SCTjCenDLA/CGH1khw42Wb7txdmAiLUlWGZX5hgQnBQn+BwEhepuJVE2Qg0Qbq4z
-kK8FvZlyb4ZCGtRxGuJezatPXfAaJL4nqtbxyVAe/JGE0dNu8/rJuB9qOKV48wTm
-lf89sge/rcqlmzI5vGqtpv4JqWU4wwT4F/VyzGB1gWVgqZNYh6P3qsPlHmepEWdE
-Ue/AqPiLAgMBAAECggEAfeVtQAwhzXaetjlDAfwmxx2x6auXNVezCCtVfkb4lmUb
-1uD0egnZVXp3I0QYSiI4Ex/wBT/72OoDvMiTMn+XlV2u663tnHZWmYg9CJDwCeD7
-rLIS3YvTKtUAZd85/ejBI++0blcKA6L6qYMYlUmVhtpWdbgenQdrD1H0tDi+W5tS
-ZQBMi0ZuhcyicYs4tovFznyteuEJVZF0Nn3kJSgP0CIS9+pw10Xjf5f6kwroy5Lm
-mNerHczL0sI0CsyNJfedJn5BMtIl7/mWvM48/UK0MEOhLhpCgEfO4uHo0gaRMLuE
-SqDuOI30an6QvhGtEjCSEp1YSwvt2jGC1f1FxlkMMQKBgQDmvrRV2lSDxvkuwKb1
-n/rLQiHo2i6mHsRp9r2OH9QqkEJELV2eEyCa3ynOw/xvo+iyVn5WBGU9w5dH/Bv7
-PRK8s/kBv4B6WjM0jOvjgl8nhGNoBJzNLvJC9oq5H9YZyIY/wlpfWTlNE2CDhiVY
-pH+7pPjIhWZoRP9zacJukSY9zQKBgQDDGsW16vOpzl8dxDff9rdAKNL9BnPIEwKH
-gOW1k8sA3G0q5ESwWa9cFSsL6/BZb4DLgpy3/AwNYh4h4gQqOPJ040HGWU27sLg0
-MCAm0lytsJd5rYkRxo/i13vjM6nrDP5rtuVm580J19wX0C4RUrxQaZJDycRHxhzn
-OwRWOXr3twKBgQCnNiNw45rDM/l3S9yxupD/opj4KMQNVdZ4A3ox+BbEEW40AbwJ
-xUqncHjXgWb5cAo80jkTFHRZYdfLLoMIeaWOYc1c2u27vInG1yhJ4jwaYvG2e0E1
-34Nny0mUBeIdJRdENQ9QcVP46sXSCfAeYHbAADjY9vLTNMz5Ufa4MS9JMQKBgDjx
-v3LxOFz/VtOhSY2cvK+FOs+O6owiwEI8ZM8ya7W8oEA8j6/I/V2q7/1yx5vS54x+
-eq9YaUwerxzEkuKf7GQhUDlMJ1v4oErbIQczrskjGZLyC2ecxLI4ongVxCpOiJN3
-tkzqqvWMgziQEmIL+9qcdYxDf35TXGxA1Ws1K6bRAoGBAOF2KcsJZzHtgduL87R1
-KOdl24CqBjfVnz4vs+TPdU250Yayvu3nGxeq75TgLPTe81INnfViPiNwc6qMuC8K
-s03CbFQE3g1tze27KsCQvvk58bOL1brlwYY7b9hkRGT5kYz97p2Mc6lGJMkSM/uX
-CIbhMm+oiN8OjQehE20W+A25
+MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDPuvKUOUEHaXgw
+4tQ8TgpylYSQzeihlj+2ovCTryRQ4jR0FrSvyN0Pmx/BamhThkvWoQf3e2kfswDN
+q+RDSJurkQmlI+a06jYUPFihRsHUYBsgdwbGbHktyMwZeNRRm/w6bQvga0gPDxF8
+2AlQl85pwMxT+VNExMPhrfUMrfuyQGWd8vdtryOzaSvM3UHmOtND1xdLA3c3itDl
+zYH84LuvRgDvBkzWpQN9G0dZ+DmdP3G4eRpFiVtkM4hmjpuij2UkIyFEC6E2OnGu
+PI9o3/uU0trLKVN4GqZOMhL1fsHd/ZzKClLMD+DjjkI+DWZzDEP8GoQkiJ1QkTcx
+lBGCt11fAgMBAAECggEBALnPEf6te9Jib+TicE8Ey2mU/j/8PrKSz6jQ9HpVdhl3
+TM3uJW77L2kvK2d5g5n6jUmNPrAKzoxRNE3EDGh2wO/kywjRJSL8QKU3GVwhC22p
+DXqrnP7NtlLSwmWiY+Afs6ybL71smMcHhm/yWdqh/zsu/lW6tdXUXxY14PSXh4T3
+YHt7YMQk7fwFtBDtrx/Tu9/HKfTHGfTYELs0OUumhEhR92xa8HDpqT1AjlvkIHBI
+u1Pncf9fMNDdXXMYtLEOaSa7tS343t5hXvaDC5IUwM2uTqKPosetjKyoFWxSUhjT
+XnSU+j9oAMWHOWCmGcK0fV3gfxVarq7DxI4jc7PeCqECgYEA/2DiBMe+2FgDc5sf
+bA70aSg8xIysnc4yXv8lS2xi2jDY7TOmzsMUoZ18iMFgQXJD2YPjs4vG1kDlH3OI
+x5gpqsiMxjkl8d2UXTGHtH/5V8hPKlzqWchLDqCb3u/lVYfz2WkhMQYc7QaGiFFP
+it07m0WHW+7r9+ZVlcg3UnFGafECgYEA0Dxgd1NACk0vGt+aYixihIWT1/yEUM1Y
+nNu9XEqy1fcw5WVyFXb4auROi6yqsZ3cfWbx+5ydCXez7Lj783MKMsc0bfq8DgAt
+CZMNdANcASI2b1hM6vSTwhk7GQcHSGqk5qJEDeomkfcZ9YSU1QAlnXLxcicYziB8
+HfxtMpr7bE8CgYBJrc4HywlIqbv1MqASMQ5a+HzvyBZVQRRPTBWaeR7cDJPJe8l4
+hdgB+MnhOslmmGzy6JZdSsqHLhnsxQyFaWU8HLhgyEQmT+NqL8wTS4jIxsXwVvZW
+CO9+vN+7pkLoNl0oMKie2ECoMeXGlo74ZXO5DIpM/9WcpBu1Jxqu8nd6QQKBgQCz
+HkxIN/cNJWlQb2iH6+/uWExc7FwQeSIxAx82ZRbBz/hiSknAxu5WW/5oTOUjFUwV
+Hlkl+ohmHW5KQLCQr7LlDM8/jv71+BbFdpWK5lzcqMY0LrszG6CBxFw+YfpUw08H
+CCsL4Q6+XdQZiarQMWkprzaa36CJpg29aWWwsvl0JwKBgQD4wxlRT/tNPitblI9c
+UxTFobgndQoehA67vW0JWxzytbySUSclp6HXPbgDZwkNX/Y+sGEaQh7convAyqnJ
+HmZMFCPuIf3kxHeyfqKf9M5ocU/EFCRIhC7N+G2psrHdPdC2NDHF9fR33W3lVBIK
+K0PUgIAhw6zvUnEAl3+TKrYInw==
 -----END PRIVATE KEY-----

data/member-b/cert.pem

@@ -1,17 +1,17 @@
 -----BEGIN CERTIFICATE-----
-MIICxDCCAawCCQCoKGH3VybuuDANBgkqhkiG9w0BAQsFADAkMRIwEAYDVQQDDAls
-b2NhbGhvc3QxDjAMBgNVBAoMBW9yZy1iMB4XDTIxMDUyMDAyMjYxNFoXDTIyMDUy
-MDAyMjYxNFowJDESMBAGA1UEAwwJbG9jYWxob3N0MQ4wDAYDVQQKDAVvcmctYjCC
-ASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAN21/OyZAHIM+6B/HdR7pQLX
-cEh60nUYHEJbCa5dlV7WyqpbKF6jSnbxz3/ZC59qHQKSgQ6Clm+AK7GaMpuN2mmN
-ZL0ycR5+Ulax+rDJ827z2j+yCUz31gL8p3/kGTe66KeYVvuG3AntCDC+rCrShkE3
-s8EzR26k1vLMavZovZVT6xfONFPPbFEGS/x8LTkC0n0gQgDAAjwVKqjXl6OGVqs4
-VsByzeHGHmmJa5hTP0ACu0y5m0R5ifd49GiOxB8zNJNOYf2vyYiinCbprjy3DZgI
-UMKyJeqFkJ+mD+Hh50tuhAZu4ffBZSDmb4AKF1z2t+2Bc1TZeDuCRBJbVZnMTB8C
-AwEAATANBgkqhkiG9w0BAQsFAAOCAQEAa/cv4g1DJI8KYFcmOdhawwAAIZxg3/G/
-rk3Y2wShftZpTFk2mEnX0KUbXnt1JKDENcwDSldDLQF5bJHPJMyjiwPNSCxwmWSv
-PzE7GwUZzUoh2Xp4sg12zaJQaHjqq6SBbv4hrpuLvuK+aSOLuN7GDuwatfouaium
-5kCOgiSZJNYw0jJy723XuZoQAmXhqY7LuxYYVipW/nRQZSdUWW53gWqjutRbvBPy
-pc+enThDeZQE8PGQw9OfhK+UavVOWfsBJMpTO416pMD1+JSfm7bJmaz43b6Pwwok
-6lPdB9Pk1fPDS60p6SGP6Ovnr66mXKKqToECIL1m3GUx8iKH7ymeHQ==
+MIICxDCCAawCCQC76ou6hDMEjDANBgkqhkiG9w0BAQsFADAkMRIwEAYDVQQDDAls
+b2NhbGhvc3QxDjAMBgNVBAoMBW9yZy1iMB4XDTIyMDcxOTIxMDEyNloXDTMyMDcx
+NjIxMDEyNlowJDESMBAGA1UEAwwJbG9jYWxob3N0MQ4wDAYDVQQKDAVvcmctYjCC
+ASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAMGBnQYxEHP+ZLzFNikeoKfU
+Ud/DBTDYhwZaRK4tPPXgGCEoFm9UvePzLOyCOXo7N47U7BNjysbD4cTCvaF2cz6W
+1mwg73rLxXB8Sv3S/jQhMkYFt8kQ1bLQvm5BYEVfftehkInROJxGpHTr88Oj4r/m
+m0v7YUEfRVkEYhbc7OKpBEE9yWRNX47NGzSJPOtjn8rJ4EYFu0CYYrMcNpGg8wtc
+Osi6kEEmHWecE8CGkj48E3iWFo/AZEAacsg2mwtsDZGkAD3qxXKlhEwu18G6iYuT
+V1yze/wo1puTf3/srIu+ZUkcjndNkyunJLtvO8jvZZVUB8gsDNepuHaAF3hAtBUC
+AwEAATANBgkqhkiG9w0BAQsFAAOCAQEAg975lC4A8iGCA67nD5vbGzWGFgxH/Kyj
+6jTZ3PIcd0gz9Mwm34HqD48hylbPpRIwMggAD6/9PnRmuZIqMhXRKMi9GtKpS+v6
+jRx7LP73aivgDUDu1IfDKnka3izy4NFo5pGQs5kk2njswoYOj63Qa/8COA7H8rLp
+qw9u0RF6j/OruvAthTltwnv0c+CkYwzz7VshVqWBrQuRAAku+nu8nYznDyYTdgaF
+IXvCbOS/vDQJWFRmrXsQx6+kDDkon6Vt4lR8TJJMwQ9s1KIFsV1Hcu92qQHhAh3V
+EtmsbnwuFOXJ5dr11HqcFKKjs1xIcsvWC04pBMk/SGS25jDB20fNdA==
 -----END CERTIFICATE-----

data/member-b/config.json

@@ -12,7 +12,7 @@
   "peers": [
     {
       "id": "org-a",
-      "endpoint": "https://localhost:3001"
+      "endpoint": "https://0.0.0.0:3001"
     }
   ]
 }

data/member-b/key.pem

@@ -1,28 +1,28 @@
 -----BEGIN PRIVATE KEY-----
-MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQDdtfzsmQByDPug
-fx3Ue6UC13BIetJ1GBxCWwmuXZVe1sqqWyheo0p28c9/2Qufah0CkoEOgpZvgCux
-mjKbjdppjWS9MnEeflJWsfqwyfNu89o/sglM99YC/Kd/5Bk3uuinmFb7htwJ7Qgw
-vqwq0oZBN7PBM0dupNbyzGr2aL2VU+sXzjRTz2xRBkv8fC05AtJ9IEIAwAI8FSqo
-15ejhlarOFbAcs3hxh5piWuYUz9AArtMuZtEeYn3ePRojsQfMzSTTmH9r8mIopwm
-6a48tw2YCFDCsiXqhZCfpg/h4edLboQGbuH3wWUg5m+AChdc9rftgXNU2Xg7gkQS
-W1WZzEwfAgMBAAECggEBAKiHwueychU/6zIYDnvLNSaQz0g5HKtnlWuXOiex+W4r
-BckzG9+8bkk2DI3ZVa1rAvxGkxWNjH7bRdtuJBP8Y08i7LWolzYfvcUq6y3hhUsM
-0BTk5477QVHp7gUYRVcIm/txoIT4AWEGLdinx8WRW/5NMjWlHiJr6PyNCK2f9qR/
-yG1Sjs2rBaAv0pPE12PNjhQ/0LvpnLXszROihe9WmXTmWJk3LuZ/BG/9i+qwir8M
-TjHwvv9cKpxOXtkADtuAVfipYEBKNPtq8hFAaILIUwit9A9OsSAbhQz9KclF0YVz
-2L2YjorwbUzO7tRi0Qvvj3KHfl4oxtOR1OG7Efd/rNkCgYEA9hhke2b3QiNbAZ1b
-vE8acOAUhnGoOwyXBA6gp67KkjZjSGgfbHzyJK61B7gVKMTYBacQ6kUNb4Hzs951
-8v9DiZIOTlkMqiohAEQ+FCNFqpqi4NdpdX7eHy0+R/CVMcMPIqqKTpQo++96dEG2
-V8YR/zTAAonvLtiRkjthtLCnjp0CgYEA5qJauLacPVcGIBN/KfV4aEOa/L8Cr2kf
-M3Zsw28fKHxghU44ArPjlml6Lcicp7IXE/vspwclIvYb599e7SdxaQHW6AWAWho/
-dF3yqE/2HN2aPWH4m98YFcNHYxtNGHgCO7hVV021lnw8jAR4m1oRQKSI43eIOl59
-5DJ6Gv7fSusCgYBmcRb664zH4lHS5T83rzIRhKXmpU9jbUU78h7cTn2SycMgc/+I
-uKZPsM447V8Zfn9yMu5uptoF7fGVkWhGBA6IKN19rcIA39Km+sFgvqIUd5SPxfvn
-Zi1uivXfGn3wngMh6h3yweghn7m4xVXzScdaFgpLxEFlnc9TMRbmEZdeXQKBgAMJ
-ekZaaT5JihQcDZ2g1OASm9TeMwvaR4Xm9lGwgemHkcHPoN8wPTv60ZgOvzlaGAG0
-XI5qgquuL/nisB5RWaX3Vzwg7mrBU7qVjh93RhdlN6W9R4fN7UREGQmOD3rWAbmF
-mOIYbN65bhat7GSnT/jY8dCE/289VU0O+Rqn5orXAoGBAKQq+E9s+avF1OZ8QMVk
-PxmoXY4DC6pttbFKTQrlVoBAaRnCUpf4KS1MHzrl8APk5wEP6Czk2k+IVqA2eqGg
-cb9HNA2jzX7JkJC3MXS4bXRbZugq/H6imFd+EmRR9KmMD6QF7NHXzKqxO4O7Ve7N
-rex3JnPj7odUG+Mh4Z3johRk
+MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDBgZ0GMRBz/mS8
+xTYpHqCn1FHfwwUw2IcGWkSuLTz14BghKBZvVL3j8yzsgjl6OzeO1OwTY8rGw+HE
+wr2hdnM+ltZsIO96y8VwfEr90v40ITJGBbfJENWy0L5uQWBFX37XoZCJ0TicRqR0
+6/PDo+K/5ptL+2FBH0VZBGIW3OziqQRBPclkTV+OzRs0iTzrY5/KyeBGBbtAmGKz
+HDaRoPMLXDrIupBBJh1nnBPAhpI+PBN4lhaPwGRAGnLINpsLbA2RpAA96sVypYRM
+LtfBuomLk1dcs3v8KNabk39/7KyLvmVJHI53TZMrpyS7bzvI72WVVAfILAzXqbh2
+gBd4QLQVAgMBAAECggEBAJcJ5li431DKljLJ9BZwc5HMJgP0Iw8XU31f5A/X+6cn
+PW5T7f8ENBvC6aPJmbeQlTMFeyc/Uz2GE6kTIBTxcc6+yasoogRFHV1JhvdMQ2LJ
+LoZ9XBCy9TpXuOwyV0SO32DMGReZmQhSE3e33FMujoSfKURLeIPuNqDezPlvg+7+
+BnqUND1juxq4mWFDq5zSiJyLFbMdP/XXsD1NHDHsOcl5BpPhdA35RNok1gxnjpqq
+VM1keLrExSxyXpu47OOEq+6NwRigC+/lsaJCj65N/GJb7gcI3pMaX/STaXXt+k1i
+g7jQc4pgLNc22XLfwC49B2K64xCU3x3iQsL1x6ymW9kCgYEA4XXDiS11JjLuyPFI
+yCgbbPWb7YcDFzSZ/YSCUZuXNtubGLsa5ymSPE8NAum1UFCiw5v1NtINUt7qNZgW
+sDueAjTF4eBchX7BP5XpHbVD8n5iTLa+k3/l6eHr2brCX7Mza2N6XkqnDeSUz1O5
+fu+aNQ9JkrFeOaXvO47u0MOuN0MCgYEA27fL490BCcs6372RAQvgY1xnCc5MnzUA
+mMiQDt0S0JD82z681kkbBD2Nu854zZKNafd3Vgf1bYQuod40EoFTmN0f3AORsKoM
+E5aNiqRKk7oQuHrIjNz7y6aXRcwYIfh1HGlPnLpRtVV3Ui8AwoOcFcpw4WOX41XB
+ArLbf+yz1ccCgYBtiSlWnB8uT9BzD8asd8/bP/hhjhaST5wA7z/hJhZxMIBJo52O
+cUP6yO0pXSIZwxNQtZSM7cBLYsGnCBz9wfkiWUFKXBaXRN3eZpa7ODWqunxHiQFN
+5/Vri7dqMLH+jLGOmuX4qYw/0634jFSytvXUkXjNLB77IwL3jJm6E1ewwQKBgHR9
+90khtNo3eUiFHmtam6ayqCLH0VIb7OwUcmSfC8mvBZFMqxxF+GAALrRjXSNJT1be
+kNP5NkPRcFP8Fsm07di/bJPfBJCRKAP+r57RSoUWgqT83HXq+ElaUxv7gNQKAjWF
+FGO5WXb2EGRvbUy0ML5Q7hZiEnbC0amXoM8rdZGjAoGASPGmRVIJCKlXm0Q4F39i
+T9E1c0frkGl5cpllDL5FBehCucHMRBvlw42P4eTUKLy1pUpkyX+wcM2DNGapnrlB
+UqlBxnIrwymADyQxr6v18WiOI5d2NCALB1U+IkZJRBOL6mycWsMu46j9MWoZbF0I
+i3Fk/uW6OEw/fX2rPco4gHE=
 -----END PRIVATE KEY-----

src/handlers/blobs.ts

@@ -21,7 +21,7 @@ import https from 'https';
 import path from 'path';
 import stream from 'stream';
 import { v4 as uuidV4 } from 'uuid';
-import { ca, cert, key } from '../lib/cert';
+import { ca, cert, key, peerID } from '../lib/cert';
 import { BlobTask, IBlobDeliveredEvent, IBlobFailedEvent, IFile, IMetadata } from "../lib/interfaces";
 import { Logger } from '../lib/logger';
 import RequestError from '../lib/request-error';
@@ -67,26 +67,37 @@ export const storeBlob = async (file: IFile, filePath: string) => {
   return await upsertMetadata(filePath, blobHash, blobSize);
 };
 
-export const sendBlob = async (blobPath: string, recipient: string, recipientURL: string, requestId: string | undefined) => {
+export const sendBlob = async (blobPath: string, recipientID: string, recipientURL: string, requestId: string | undefined,
+  senderDestination: string | undefined, recipientDestination: string | undefined) => {
   if (sending) {
-    blobQueue.push({ blobPath, recipient, recipientURL, requestId });
+    blobQueue.push({ blobPath, recipientID, recipientURL, requestId, senderDestination, recipientDestination });
   } else {
     sending = true;
-    blobQueue.push({ blobPath, recipient, recipientURL, requestId });
+    blobQueue.push({ blobPath, recipientID, recipientURL, requestId, senderDestination, recipientDestination });
     while (blobQueue.length > 0) {
       await deliverBlob(blobQueue.shift()!);
     }
     sending = false;
   }
 };
 
-export const deliverBlob = async ({ blobPath, recipient, recipientURL, requestId }: BlobTask) => {
+export const deliverBlob = async ({ blobPath, recipientID, recipientURL, requestId, senderDestination, recipientDestination }: BlobTask) => {
   const resolvedFilePath = path.join(utils.constants.DATA_DIRECTORY, utils.constants.BLOBS_SUBDIRECTORY, blobPath);
   if (!(await utils.fileExists(resolvedFilePath))) {
     throw new RequestError('Blob not found', 404);
   }
   const stream = createReadStream(resolvedFilePath);
   const formData = new FormData();
+  let sender = peerID;
+  if(senderDestination !== undefined) {
+    formData.append('senderDestination', senderDestination);
+    sender += utils.constants.ID_SEGMENT_SEPARATOR + senderDestination
+  }
+  let recipient = recipientID;
+  if(recipientDestination !== undefined) {
+    formData.append('recipientDestination', recipientDestination);
+    recipient += utils.constants.ID_SEGMENT_SEPARATOR + recipientDestination;
+  }
   formData.append('blob', stream);
   const httpsAgent = new https.Agent({ cert, key, ca });
   log.trace(`Delivering blob ${blobPath} to ${recipient} at ${recipientURL}`);
@@ -103,6 +114,7 @@ export const deliverBlob = async ({ blobPath, recipient, recipientURL, requestId
       id: uuidV4(),
       type: 'blob-delivered',
       path: blobPath,
+      sender,
       recipient,
       requestId
     } as IBlobDeliveredEvent);
@@ -112,6 +124,7 @@ export const deliverBlob = async ({ blobPath, recipient, recipientURL, requestId
       id: uuidV4(),
       type: 'blob-failed',
       path: blobPath,
+      sender,
       recipient,
       requestId,
       error: err.message,

src/handlers/messages.ts

@@ -17,33 +17,44 @@
 import FormData from 'form-data';
 import https from 'https';
 import { v4 as uuidV4 } from 'uuid';
-import { ca, cert, key } from '../lib/cert';
+import { ca, cert, key, peerID } from '../lib/cert';
 import { IMessageDeliveredEvent, IMessageFailedEvent, MessageTask } from '../lib/interfaces';
 import { Logger } from '../lib/logger';
 import * as utils from '../lib/utils';
 import { queueEvent } from './events';
 
-const log = new Logger('handlers/messages.ts')
+const log = new Logger('handlers/messages.ts');
 
 let messageQueue: MessageTask[] = [];
 let sending = false;
 
-export const sendMessage = async (message: string, recipient: string, recipientURL: string, requestId: string | undefined) => {
+export const sendMessage = async (message: string, recipientID: string, recipientURL: string, requestId: string | undefined,
+  senderDestination: string | undefined, recipientDestination: string | undefined) => {
   if (sending) {
-    messageQueue.push({ message, recipient, recipientURL, requestId });
+    messageQueue.push({ message, recipientID, recipientURL, requestId, senderDestination, recipientDestination });
   } else {
     sending = true;
-    messageQueue.push({ message, recipient, recipientURL, requestId });
+    messageQueue.push({ message, recipientID, recipientURL, requestId, senderDestination, recipientDestination });
     while (messageQueue.length > 0) {
       await deliverMessage(messageQueue.shift()!);
     }
     sending = false;
   }
 };
 
-export const deliverMessage = async ({ message, recipient, recipientURL, requestId }: MessageTask) => {
+export const deliverMessage = async ({ message, recipientID, recipientURL, requestId, senderDestination, recipientDestination }: MessageTask) => {
   const httpsAgent = new https.Agent({ cert, key, ca });
   const formData = new FormData();
+  let sender = peerID;
+  if(senderDestination !== undefined) {
+    formData.append('senderDestination', senderDestination);
+    sender += utils.constants.ID_SEGMENT_SEPARATOR + senderDestination
+  }
+  let recipient = recipientID;
+  if(recipientDestination !== undefined) {
+    formData.append('recipientDestination', recipientDestination);
+    recipient += utils.constants.ID_SEGMENT_SEPARATOR + recipientDestination;
+  }
   formData.append('message', message);
   log.trace(`Delivering message to ${recipient} at ${recipientURL}`);
   try {
@@ -58,6 +69,7 @@ export const deliverMessage = async ({ message, recipient, recipientURL, request
       id: uuidV4(),
       type: 'message-delivered',
       message,
+      sender,
       recipient,
       requestId
     } as IMessageDeliveredEvent);
@@ -67,6 +79,7 @@ export const deliverMessage = async ({ message, recipient, recipientURL, request
       id: uuidV4(),
       type: 'message-failed',
       message,
+      sender,
       recipient,
       requestId,
       error: err.message,

src/lib/cert.ts

@@ -76,7 +76,7 @@ export const genTLSContext = () => {
     key,
     cert,
     ca,
-    rejectUnauthorized: true,
+    rejectUnauthorized: Boolean(process.env.NODE_TLS_REJECT_UNAUTHORIZED === '0'? false: true),
     requestCert: true,
   }
 }