Integration with Hedera Hashgraph

Signed-off-by: Stoyan Panayotov <[email protected]>

Author: stoqnkpL

.gitignore

@@ -1,3 +1,5 @@
 db/
 .env
 external-initiator
+.DS_STORE
+.idea

blockchain/common.go

@@ -46,13 +46,15 @@ var blockchains = []string{
 	BIRITA,
 	Agoric,
 	Klaytn,
+	HEDERA,
 }
 
 type Params struct {
 	Endpoint    string   `json:"endpoint"`
 	Addresses   []string `json:"addresses"`
 	Topics      []string `json:"topics"`
 	AccountIds  []string `json:"accountIds"`
+	AccountId   string   `json:"accountId"`
 	Address     string   `json:"address"`
 	UpkeepID    string   `json:"upkeepId"`
 	ServiceName string   `json:"serviceName"`
@@ -98,6 +100,8 @@ func CreateClientManager(sub store.Subscription) (subscriber.ISubscriber, error)
 		return createKeeperSubscriber(sub)
 	case BIRITA:
 		return createBSNIritaSubscriber(sub)
+	case HEDERA:
+		return createHederaSubscriber(sub), nil
 	}
 
 	return nil, errors.New("unknown blockchain type for Client subscription")
@@ -106,7 +110,7 @@ func CreateClientManager(sub store.Subscription) (subscriber.ISubscriber, error)
 func GetConnectionType(endpoint store.Endpoint) (subscriber.Type, error) {
 	switch endpoint.Type {
 	// Add blockchain implementations that encapsulate entire connection here
-	case XTZ, ONT, IOTX, Keeper, BIRITA:
+	case XTZ, ONT, IOTX, Keeper, BIRITA, HEDERA:
 		return subscriber.Client, nil
 	default:
 		u, err := url.Parse(endpoint.Url)
@@ -177,6 +181,10 @@ func GetValidations(t string, params Params) []int {
 		return []int{
 			1,
 		}
+	case HEDERA:
+		return []int{
+			len(params.AccountId),
+		}
 	}
 
 	return nil
@@ -228,6 +236,10 @@ func CreateSubscription(sub *store.Subscription, params Params) {
 		}
 	case Agoric:
 		sub.Agoric = store.AgoricSubscription{}
+	case HEDERA:
+		sub.Hedera = store.HederaSubscription{
+			AccountId: params.AccountId,
+		}
 	}
 }