first topic transactions

Author: hendrikebbers

hedera-base/src/main/java/com/openelements/hedera/base/implementation/ProtocolLayerClientImpl.java

@@ -20,11 +20,13 @@
 import com.hedera.hashgraph.sdk.PrivateKey;
 import com.hedera.hashgraph.sdk.PublicKey;
 import com.hedera.hashgraph.sdk.Query;
+import com.hedera.hashgraph.sdk.TopicCreateTransaction;
+import com.hedera.hashgraph.sdk.TopicDeleteTransaction;
+import com.hedera.hashgraph.sdk.TopicMessageSubmitTransaction;
 import com.hedera.hashgraph.sdk.Transaction;
 import com.hedera.hashgraph.sdk.TransactionReceipt;
 import com.hedera.hashgraph.sdk.TransactionRecord;
 import com.hedera.hashgraph.sdk.TransactionResponse;
-import com.hedera.hashgraph.sdk.proto.ConsensusCreateTopic;
 import com.openelements.hedera.base.ContractParam;
 import com.openelements.hedera.base.HederaException;
 import com.openelements.hedera.base.protocol.AccountBalanceRequest;
@@ -52,6 +54,11 @@
 import com.openelements.hedera.base.protocol.FileUpdateRequest;
 import com.openelements.hedera.base.protocol.FileUpdateResult;
 import com.openelements.hedera.base.protocol.ProtocolLayerClient;
+import com.openelements.hedera.base.protocol.TopicCreateResult;
+import com.openelements.hedera.base.protocol.TopicDeleteRequest;
+import com.openelements.hedera.base.protocol.TopicDeleteResult;
+import com.openelements.hedera.base.protocol.TopicSubmitMessageRequest;
+import com.openelements.hedera.base.protocol.TopicSubmitMessageResult;
 import edu.umd.cs.findbugs.annotations.NonNull;
 import java.util.List;
 import java.util.Objects;
@@ -243,6 +250,44 @@ public AccountDeleteResult executeAccountDeleteTransaction(@NonNull final Accoun
         return new AccountDeleteResult(record.transactionId, record.receipt.status, record.transactionHash, record.consensusTimestamp, record.transactionFee);
     }
 
+    public TopicCreateResult executeTopicCreateTransaction() throws HederaException {
+        try {
+            final TopicCreateTransaction transaction = new TopicCreateTransaction();
+            final TransactionResponse response = transaction.execute(client);
+            final TransactionReceipt receipt = response.getReceipt(client);
+            return new TopicCreateResult(receipt.transactionId, receipt.status, receipt.topicId);
+        } catch (final Exception e) {
+            throw new HederaException("Failed to execute create topic transaction", e);
+        }
+    }
+
+    public TopicDeleteResult executeTopicDeleteTransaction(@NonNull final TopicDeleteRequest request) throws HederaException {
+        Objects.requireNonNull(request, "request must not be null");
+        try {
+            final TopicDeleteTransaction transaction = new TopicDeleteTransaction();
+            transaction.setTopicId(request.topicId());
+            final TransactionResponse response = transaction.execute(client);
+            final TransactionReceipt receipt = response.getReceipt(client);
+            return new TopicDeleteResult(receipt.transactionId, receipt.status);
+        } catch (final Exception e) {
+            throw new HederaException("Failed to execute create topic transaction", e);
+        }
+    }
+
+    public TopicSubmitMessageResult executeTopicMessageSubmitTransaction(@NonNull final TopicSubmitMessageRequest request) throws HederaException {
+        Objects.requireNonNull(request, "request must not be null");
+        try {
+            final TopicMessageSubmitTransaction transaction = new TopicMessageSubmitTransaction();
+            transaction.setTopicId(request.topicId());
+            transaction.setMessage(request.message());
+            final TransactionResponse response = transaction.execute(client);
+            final TransactionReceipt receipt = response.getReceipt(client);
+            return new TopicSubmitMessageResult(receipt.transactionId, receipt.status);
+        } catch (final Exception e) {
+            throw new HederaException("Failed to execute create topic transaction", e);
+        }
+    }
+
     @NonNull
     private ContractFunctionParameters createParameters(@NonNull List<ContractParam<?>> params) {
         Objects.requireNonNull(params, "params must not be null");

hedera-base/src/main/java/com/openelements/hedera/base/protocol/TopicCreateResult.java

@@ -0,0 +1,9 @@
+package com.openelements.hedera.base.protocol;
+
+import com.hedera.hashgraph.sdk.Status;
+import com.hedera.hashgraph.sdk.TopicId;
+import com.hedera.hashgraph.sdk.TransactionId;
+
+public record TopicCreateResult(TransactionId transactionId, Status status, TopicId fileId) implements TransactionResult{
+
+}

hedera-base/src/main/java/com/openelements/hedera/base/protocol/TopicDeleteRequest.java

@@ -0,0 +1,25 @@
+package com.openelements.hedera.base.protocol;
+
+import com.hedera.hashgraph.sdk.FileId;
+import com.hedera.hashgraph.sdk.Hbar;
+import com.hedera.hashgraph.sdk.TopicId;
+import edu.umd.cs.findbugs.annotations.NonNull;
+import edu.umd.cs.findbugs.annotations.Nullable;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.Objects;
+
+public record TopicDeleteRequest(Hbar maxTransactionFee,
+
+                                 Duration transactionValidDuration,
+
+                                 @NonNull TopicId topicId) implements TransactionRequest {
+
+    public TopicDeleteRequest {
+       Objects.requireNonNull(topicId, "TopicId cannot be null");
+    }
+
+    public static TopicDeleteRequest of(@NonNull TopicId topicId) {
+        return new TopicDeleteRequest(DEFAULT_MAX_TRANSACTION_FEE, DEFAULT_TRANSACTION_VALID_DURATION, topicId);
+    }
+}

hedera-base/src/main/java/com/openelements/hedera/base/protocol/TopicDeleteResult.java

@@ -0,0 +1,9 @@
+package com.openelements.hedera.base.protocol;
+
+import com.hedera.hashgraph.sdk.Status;
+import com.hedera.hashgraph.sdk.TopicId;
+import com.hedera.hashgraph.sdk.TransactionId;
+
+public record TopicDeleteResult(TransactionId transactionId, Status status) implements TransactionResult{
+
+}

hedera-base/src/main/java/com/openelements/hedera/base/protocol/TopicSubmitMessageRequest.java

@@ -0,0 +1,35 @@
+package com.openelements.hedera.base.protocol;
+
+import com.hedera.hashgraph.sdk.Hbar;
+import com.hedera.hashgraph.sdk.TopicId;
+import edu.umd.cs.findbugs.annotations.NonNull;
+import java.nio.charset.StandardCharsets;
+import java.time.Duration;
+import java.util.Objects;
+
+public record TopicSubmitMessageRequest(Hbar maxTransactionFee,
+
+                                        Duration transactionValidDuration,
+
+                                        @NonNull TopicId topicId,
+                                        @NonNull byte[] message) implements TransactionRequest {
+
+    static final int MAX_MESSAGE_LENGTH = 1024;
+
+    public TopicSubmitMessageRequest {
+       Objects.requireNonNull(topicId, "TopicId cannot be null");
+         Objects.requireNonNull(message, "Message cannot be null");
+         if(message.length > MAX_MESSAGE_LENGTH) {
+             throw new IllegalArgumentException("Message cannot be longer than " + MAX_MESSAGE_LENGTH + " bytes");
+         }
+    }
+
+    public static TopicSubmitMessageRequest of(@NonNull TopicId topicId, @NonNull String message) {
+        Objects.requireNonNull(message, "Message cannot be null");
+        return new TopicSubmitMessageRequest(DEFAULT_MAX_TRANSACTION_FEE, DEFAULT_TRANSACTION_VALID_DURATION, topicId, message.getBytes(StandardCharsets.UTF_8));
+    }
+
+    public static TopicSubmitMessageRequest of(@NonNull TopicId topicId, @NonNull byte[] message) {
+        return new TopicSubmitMessageRequest(DEFAULT_MAX_TRANSACTION_FEE, DEFAULT_TRANSACTION_VALID_DURATION, topicId, message);
+    }
+}

hedera-base/src/main/java/com/openelements/hedera/base/protocol/TopicSubmitMessageResult.java

@@ -0,0 +1,8 @@
+package com.openelements.hedera.base.protocol;
+
+import com.hedera.hashgraph.sdk.Status;
+import com.hedera.hashgraph.sdk.TransactionId;
+
+public record TopicSubmitMessageResult(TransactionId transactionId, Status status) implements TransactionResult{
+
+}