From 33e41ae2e4eb3261b0fa53545bbf0a34a0f0d709 Mon Sep 17 00:00:00 2001
From: Andrei Kuzmiankov <ender2016@gmail.com>
Date: Fri, 16 Oct 2020 04:15:05 -0700
Subject: [PATCH] feat: Added topic_info_query

---
 topic_info_query.go | 99 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 99 insertions(+)
 create mode 100644 topic_info_query.go

diff --git a/topic_info_query.go b/topic_info_query.go
new file mode 100644
index 000000000..ada6abc3f
--- /dev/null
+++ b/topic_info_query.go
@@ -0,0 +1,99 @@
+package hedera
+
+import (
+	"github.com/hashgraph/hedera-sdk-go/proto"
+)
+
+type TopicInfoQuery struct {
+	Query
+	pb *proto.ConsensusGetTopicInfoQuery
+}
+
+// NewTopicInfoQuery creates a TopicInfoQuery query which can be used to construct and execute a
+//  Get Topic Info Query.
+func NewTopicInfoQuery() *TopicInfoQuery {
+	header := proto.QueryHeader{}
+	query := newQuery(true, &header)
+	pb := proto.ConsensusGetTopicInfoQuery{Header: &header}
+	query.pb.Query = &proto.Query_ConsensusGetTopicInfo{
+		ConsensusGetTopicInfo: &pb,
+	}
+
+	return &TopicInfoQuery{
+		Query: query,
+		pb:    &pb,
+	}
+}
+
+// SetTopicID sets the topic to retrieve info about (the parameters and running state of).
+func (query *TopicInfoQuery) SetTopicID(id TopicID) *TopicInfoQuery {
+	query.pb.TopicID = id.toProtobuf()
+	return query
+}
+
+// Execute executes the TopicInfoQuery using the provided client
+func (query *TopicInfoQuery) Execute(client *Client) (TopicInfo, error) {
+	if client == nil || client.operator == nil {
+		return TopicInfo{}, errNoClientProvided
+	}
+
+	query.queryPayment = NewHbar(2)
+	query.paymentTransactionID = TransactionIDGenerate(client.operator.accountID)
+
+	var cost Hbar
+	if query.queryPayment.tinybar != 0 {
+		cost = query.queryPayment
+	} else {
+		cost = client.maxQueryPayment
+
+		// actualCost := CostQuery()
+	}
+
+	err := query_generatePayments(&query.Query, client, cost)
+	if err != nil {
+		return TopicInfo{}, err
+	}
+
+
+	resp, err := execute(
+		client,
+		request{
+			query: &query.Query,
+		},
+		query_shouldRetry,
+		query_makeRequest,
+		query_advanceRequest,
+		query_getNodeId,
+		networkVersionInfoQuery_getMethod,
+		networkVersionInfoQuery_mapResponseStatus,
+		query_mapResponse,
+	)
+
+	if err != nil {
+		return TopicInfo{}, err
+	}
+
+	//ti := resp.query.GetConsensusGetTopicInfo().TopicInfo
+	//
+	//TopicInfo := topicinfo
+	//
+	//if adminKey := ti.AdminKey; adminKey != nil {
+	//	TopicInfo.AdminKey = &Ed25519PublicKey{
+	//		keyData: adminKey.GetEd25519(),
+	//	}
+	//}
+	//
+	//if submitKey := ti.SubmitKey; submitKey != nil {
+	//	TopicInfo.SubmitKey = &Ed25519PublicKey{
+	//		keyData: submitKey.GetEd25519(),
+	//	}
+	//}
+	//
+	//if ARAccountID := ti.AutoRenewAccount; ARAccountID != nil {
+	//	ID := accountIDFromProto(ARAccountID)
+	//
+	//	TopicInfo.AutoRenewAccountID = &ID
+	//}
+
+	return topicInfoFromProtobuf(resp.query.GetConsensusGetTopicInfo().TopicInfo), nil
+}