Merge mip 118

gamification-evm-services/pom.xml

@@ -44,6 +44,27 @@
       <groupId>io.meeds.gamification</groupId>
       <artifactId>gamification-services</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.meeds.wallet</groupId>
+      <artifactId>wallet-api</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.exoplatform.wallet</groupId>
+      <artifactId>ert-contract</artifactId>
+      <scope>provided</scope>
+      <exclusions>
+        <exclusion>
+          <groupId>*</groupId>
+          <artifactId>*</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+
+    <dependency>
+      <groupId>org.web3j</groupId>
+      <artifactId>core</artifactId>
+    </dependency>
   </dependencies>
   <build>
     <finalName>gamification-evm-service</finalName>

gamification-evm-services/src/main/java/io/meeds/evm/gamification/blockchain/BlockchainConfiguration.java

@@ -0,0 +1,30 @@
+/*
+ * This file is part of the Meeds project (https://meeds.io/).
+ * Copyright (C) 2020 - 2024 Meeds Association contact@meeds.io
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ */
+package io.meeds.evm.gamification.blockchain;
+
+import org.springframework.context.annotation.Configuration;
+
+import org.web3j.protocol.Web3j;
+import org.web3j.protocol.http.HttpService;
+
+@Configuration
+public class BlockchainConfiguration {
+
+    public Web3j getNetworkWeb3j(String networkUrl) {
+      return Web3j.build(new HttpService(networkUrl));
+    }
+
+}

gamification-evm-services/src/main/java/io/meeds/evm/gamification/blockchain/BlockchainConfigurationProperties.java

@@ -0,0 +1,35 @@
+/*
+ * This file is part of the Meeds project (https://meeds.io/).
+ * Copyright (C) 2020 - 2024 Meeds Association contact@meeds.io
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ */
+package io.meeds.evm.gamification.blockchain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConfigurationProperties(prefix = "meeds.gamification.evm.blockchain")
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class BlockchainConfigurationProperties {
+
+  private String polygonNetworkUrl;
+
+  private String networkUrl;
+
+}

gamification-evm-services/src/main/java/io/meeds/evm/gamification/dao/EvmTransactionDAO.java

@@ -0,0 +1,48 @@
+/*
+ * This file is part of the Meeds project (https://meeds.io/).
+ *
+ * Copyright (C) 2020 - 2024 Meeds Association contact@meeds.io
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ */
+package io.meeds.evm.gamification.dao;
+
+import io.meeds.evm.gamification.entity.EvmTransactionEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface EvmTransactionDAO extends JpaRepository<EvmTransactionEntity, Long> {
+
+  EvmTransactionEntity findTopByContractAddressAndNetworkIdAndFromAddressOrderByIdDesc(String contractAddress, Long networkId, String fromAddress);
+  @Query("""
+          SELECT DISTINCT fromAddress AS address FROM EvmTransaction tr
+          WHERE tr.contractAddress = ?1 AND tr.transactionDate >= ?2 AND tr.networkId = ?3
+          UNION
+          SELECT DISTINCT toAddress AS address FROM EvmTransaction tr
+          WHERE tr.contractAddress = ?1 AND tr.transactionDate >= ?2 AND tr.networkId = ?3
+      """)
+  List<String> findDistinctAddresses(String contractAddress, Long ruleCreationDate, Long networkId);
+
+  List<EvmTransactionEntity> findByContractAddressAndNetworkIdAndToAddressAndTransactionDateGreaterThan(String contractAddress,
+                                                                                                        Long networkId,
+                                                                                                        String toAddress,
+                                                                                                        Long transactionDate);
+
+  List<EvmTransactionEntity> findByContractAddressAndNetworkIdAndFromAddressAndTransactionDateGreaterThan(String contractAddress,
+                                                                                                          Long networkId,
+                                                                                                          String fromAddress,
+                                                                                                          Long transactionDate);
+}

gamification-evm-services/src/main/java/io/meeds/evm/gamification/entity/EvmTransactionEntity.java

@@ -0,0 +1,70 @@
+/*
+ * This file is part of the Meeds project (https://meeds.io/).
+ *
+ * Copyright (C) 2020 - 2024 Meeds Association contact@meeds.io
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ */
+package io.meeds.evm.gamification.entity;
+
+import jakarta.persistence.*;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigInteger;
+
+@Entity(name = "EvmTransaction")
+@Table(name = "EVM_TRANSACTIONS")
+@Data
+public class EvmTransactionEntity implements Serializable {
+
+  @Id
+  @SequenceGenerator(name = "SEQ_EVM_TRANSACTIONS_ID", sequenceName = "SEQ_EVM_TRANSACTIONS_ID", allocationSize = 1)
+  @GeneratedValue(strategy = GenerationType.AUTO, generator = "SEQ_EVM_TRANSACTIONS_ID")
+  @Column(name = "ID", nullable = false)
+  private Long       id;
+
+  @Column(name = "TRANSACTION_HASH", nullable = false)
+  private String     transactionHash;
+
+  @Column(name = "NETWORK_ID", nullable = false)
+  private Long       networkId;
+
+  @Column(name = "FROM_ADDRESS", nullable = false)
+  private String     fromAddress;
+
+  @Column(name = "TO_ADDRESS", nullable = false)
+  private String     toAddress;
+
+  @Column(name = "CONTRACT_ADDRESS", nullable = false)
+  private String     contractAddress;
+
+  @Column(name = "TRANSACTION_DATE", nullable = false)
+  private Long       transactionDate;
+
+  @Column(name = "AMOUNT")
+  private BigInteger amount;
+
+  @Column(name = "TOKEN_ID")
+  private BigInteger tokenId;
+
+  @Column(name = "WALLET_BALANCE", nullable = false)
+  private BigInteger walletBalance;
+
+  @Column(name = "BLOCK_NUMBER", nullable = false)
+  private BigInteger blockNumber;
+
+  @Column(name = "BLOCK_HASH", nullable = false)
+  private String     blockHash;
+}

gamification-evm-services/src/main/java/io/meeds/evm/gamification/listener/RuleCheckForHoldEventListener.java

@@ -0,0 +1,146 @@
+/*
+ * This file is part of the Meeds project (https://meeds.io/).
+ * Copyright (C) 2020 - 2024 Meeds Association contact@meeds.io
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ */
+package io.meeds.evm.gamification.listener;
+
+import jakarta.annotation.PostConstruct;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import io.meeds.wallet.model.Wallet;
+import io.meeds.evm.gamification.model.EvmTransaction;
+import io.meeds.evm.gamification.service.EvmBlockchainService;
+import io.meeds.evm.gamification.service.EvmContractTransferService;
+import io.meeds.evm.gamification.service.EvmTransactionService;
+import io.meeds.evm.gamification.utils.Utils;
+import io.meeds.gamification.model.RuleDTO;
+import io.meeds.gamification.service.RuleService;
+import io.meeds.wallet.service.WalletAccountService;
+
+import org.exoplatform.commons.api.persistence.ExoTransactional;
+import org.exoplatform.services.listener.Event;
+import org.exoplatform.services.listener.Listener;
+import org.exoplatform.services.listener.ListenerService;
+import org.exoplatform.social.core.space.model.Space;
+import org.exoplatform.social.core.space.spi.SpaceService;
+
+import java.math.BigInteger;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import static io.meeds.evm.gamification.utils.Utils.*;
+import static io.meeds.gamification.utils.Utils.POST_CREATE_RULE_EVENT;
+import static io.meeds.gamification.utils.Utils.POST_UPDATE_RULE_EVENT;
+import static io.meeds.gamification.utils.Utils.getUserIdentity;
+
+@Component
+public class RuleCheckForHoldEventListener extends Listener<Long, String> {
+  private static final List<String>  SUPPORTED_EVENTS = Arrays.asList(POST_CREATE_RULE_EVENT, POST_UPDATE_RULE_EVENT);
+
+  @Autowired
+  private ListenerService            listenerService;
+
+  @Autowired
+  private RuleService                ruleService;
+
+  @Autowired
+  private SpaceService               spaceService;
+
+  @Autowired
+  private WalletAccountService       walletAccountService;
+
+  @Autowired
+  private EvmBlockchainService       evmBlockchainService;
+
+  @Autowired
+  private EvmTransactionService      evmTransactionService;
+
+  @Autowired
+  private EvmContractTransferService evmContractTransferService;
+
+  @PostConstruct
+  public void init() {
+    for (String eventName : SUPPORTED_EVENTS) {
+      listenerService.addListener(eventName, this);
+    }
+  }
+
+  @Override
+  @ExoTransactional
+  public void onEvent(Event<Long, String> event) {
+    Long ruleId = event.getSource();
+    RuleDTO evmRule = ruleService.findRuleById(ruleId);
+    Boolean enabledProg = evmRule.getProgram().isEnabled();
+    String trigger = evmRule.getEvent().getTrigger();
+    if (enabledProg && trigger.equals(HOLD_TOKEN_EVENT)) {
+      Long spaceId = evmRule.getProgram().getSpaceId();
+      String contractAddress = evmRule.getEvent().getProperties().get(Utils.CONTRACT_ADDRESS).toLowerCase();
+      String blockchainNetwork = evmRule.getEvent().getProperties().get(Utils.BLOCKCHAIN_NETWORK);
+      Long networkId = Long.parseLong(evmRule.getEvent().getProperties().get(Utils.NETWORK_ID));
+      Long duration = Long.parseLong(evmRule.getEvent().getProperties().get(Utils.DURATION));
+      org.web3j.abi.datatypes.Event blockchainEvent;
+      if (evmBlockchainService.isERC1155(blockchainNetwork, contractAddress)) {
+        blockchainEvent = TRANSFERSINGLE_EVENT;
+      } else if (evmBlockchainService.isERC721(blockchainNetwork, contractAddress)) {
+        blockchainEvent = TRANSFER_EVENT_ER721;
+      } else {
+        blockchainEvent = TRANSFER_EVENT_ERC20;
+      }
+      if (spaceId == 0) {
+        Set<Wallet> wallets = walletAccountService.listWallets();
+        List<String> walletsAddresses = wallets.stream().map(Wallet::getAddress).collect(Collectors.toList());
+        walletsAddresses.forEach(walletAddress -> {
+          if (event.getEventName().equals(POST_CREATE_RULE_EVENT)) {
+            evmContractTransferService.handleHoldEvent(blockchainNetwork,
+                                                       contractAddress,
+                                                       walletAddress,
+                                                       networkId,
+                                                       duration,
+                                                       evmRule,
+                                                       blockchainEvent,
+                                                       trigger,
+                                                       null);
+
+          } else if (event.getEventName().equals(POST_UPDATE_RULE_EVENT)) {
+            evmContractTransferService.saveLastRewardTime(walletAddress, evmRule.getId());
+          }
+        });
+
+      } else {
+        Space space = spaceService.getSpaceById(String.valueOf(spaceId));
+        String[] members = space.getMembers();
+        Arrays.stream(members).forEach(member -> {
+          Long identityId = Long.parseLong(getUserIdentity(member).getId());
+          String walletAddress = walletAccountService.getWalletByIdentityId(identityId).getAddress();
+          if (event.getEventName().equals(POST_CREATE_RULE_EVENT)) {
+            evmContractTransferService.handleHoldEvent(blockchainNetwork,
+                                                       contractAddress,
+                                                       walletAddress,
+                                                       networkId,
+                                                       duration,
+                                                       evmRule,
+                                                       blockchainEvent,
+                                                       trigger,
+                                                       null);
+          } else if (event.getEventName().equals(POST_UPDATE_RULE_EVENT)) {
+            evmContractTransferService.saveLastRewardTime(walletAddress, evmRule.getId());
+          }
+        });
+      }
+    }
+  }
+}