Merge pull request #13 from yerim216/nft

Nft 개발

.gitignore

@@ -1,3 +1,4 @@
+application.yml
 HELP.md
 .gradle
 build/

build.gradle

@@ -31,10 +31,16 @@ dependencies {
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
 
 	// swagger
+	implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.2.0")
+
+	//web3j
+	implementation 'org.web3j:core:4.9.6'
+
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.2.0'
 
 	// s3
 	implementation 'org.springframework.cloud:spring-cloud-starter-aws:2.2.6.RELEASE'
+
 }
 
 tasks.named('test') {

src/main/java/zerobibim/flory/domain/contract/controller/NftController.java

@@ -0,0 +1,32 @@
+package zerobibim.flory.domain.contract.controller;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import zerobibim.flory.domain.contract.NFT;
+import zerobibim.flory.domain.contract.NFT.*;
+
+import java.math.BigInteger;
+
+@RestController
+@RequestMapping("/api/nft")
+public class NftController {
+  private final NFT nft;
+
+  @Autowired
+  public NftController(NFT nft) {
+    this.nft = nft;
+  }
+
+  // Define your API endpoints here
+  @PostMapping("/mint")
+  public String mintToken(@RequestParam String to, @RequestParam BigInteger tokenId, @RequestParam String uri) {
+    try {
+      // Mint a new token
+      return "Token minted successfully";
+    } catch (Exception e) {
+      // Handle exceptions appropriately (e.g., log the error)
+      return "Error minting token: " + e.getMessage();
+    }
+  }
+}

src/main/java/zerobibim/flory/domain/contract/dto/NFTRequestDto.java

@@ -0,0 +1,16 @@
+package zerobibim.flory.domain.contract.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+public class NFTRequestDto {
+  @Getter
+  @NoArgsConstructor
+  @AllArgsConstructor
+  public static class MemberNFTInfo {
+      private String walletAddress;
+      private String ipfsUrl;
+  }
+
+}

src/main/java/zerobibim/flory/domain/contract/service/IPFSPhotoService.java

@@ -0,0 +1,38 @@
+package zerobibim.flory.domain.contract.service;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import okhttp3.*;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+
+@Service
+public class IPFSPhotoService {
+
+  @Value("${pinata.JWT}")
+  private String PINATE_JWT;
+  public String insertIpfs(Long memberPhotoId) throws IOException {
+
+    OkHttpClient client = new OkHttpClient();
+
+    MediaType mediaType = MediaType.parse("application/json");
+    RequestBody body = RequestBody.create(mediaType, "{\"pinataContent\":{\"name\": \"" +memberPhoto.getName() + "\""
+        + ",\"description\":\"" + memberPhoto.getDescription() + "\",\"image\":\"" + memberPhoto.getImageUrl() + "\"}}");
+
+    Request request = new Request.Builder()
+        .url("https://api.pinata.cloud/pinning/pinJSONToIPFS")
+        .post(body)
+        .addHeader("Authorization", PINATA_JWT)
+        .addHeader("accept", "application/json")
+        .addHeader("content-type", "application/json")
+        .build();
+
+    ResponseBody responsebody = client.newCall(request).execute().body();
+    ObjectMapper mapper = new ObjectMapper();
+    assert responsebody != null;
+    JsonNode jsonNode = mapper.readTree(responsebody.byteStream());
+    return jsonNode.get("IpfsHash").asText();
+  }
+}

src/main/java/zerobibim/flory/domain/contract/service/Web3jService.java

@@ -0,0 +1,34 @@
+package zerobibim.flory.domain.contract.service;
+
+import org.springframework.beans.factory.annotation.Value;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.web3j.abi.EventEncoder;
+import org.web3j.abi.datatypes.generated.Uint256;
+import org.web3j.protocol.Web3j;
+import org.web3j.protocol.core.DefaultBlockParameter;
+import org.web3j.protocol.core.DefaultBlockParameterName;
+import org.web3j.protocol.core.methods.response.*;
+import zerobibim.flory.domain.contract.NFT;
+import zerobibim.flory.domain.contract.dto.NFTRequestDto;
+
+import java.math.BigInteger;
+import java.util.Arrays;
+import java.util.concurrent.ExecutionException;
+
+@Slf4j
+@RequiredArgsConstructor
+@Service("web3jService")
+public class Web3jService {
+
+  private final NFT nft;
+
+  public TransactionReceipt nftCreate(NFTRequestDto.MemberNFTInfo memberNFTInfo) throws Exception {
+
+    return nft.mint(memberNFTInfo.getWalletAddress(), "ipfs://" +)
+        .sendAsync()
+        .get();
+  }
+
+}

src/main/java/zerobibim/flory/global/config/Web3jConfig.java

@@ -0,0 +1,47 @@
+package zerobibim.flory.global.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.web3j.crypto.Credentials;
+import org.web3j.crypto.ECKeyPair;
+import org.web3j.protocol.Web3j;
+import org.web3j.protocol.http.HttpService;
+import org.web3j.tx.Contract;
+import org.web3j.tx.gas.StaticGasProvider;
+import zerobibim.flory.domain.contract.NFT;
+
+import java.math.BigInteger;
+
+@Configuration
+public class Web3jConfig {
+
+  @Value("${infura.API_URL}")
+  private String INFURA_API_URL;
+
+  @Value("${metamask.PRIVATE_KEY}")
+  private String PRIVATE_KEY;
+
+  @Value("${metamask.CONTRACT_ADDRESS}")
+  private String CONTRACT_ADDRESS;
+
+  @Bean
+  public Web3j web3j() {
+    return Web3j.build(new HttpService(INFURA_API_URL));
+  }
+
+  @Bean
+  public Credentials credentials() {
+    BigInteger privateKeyInBT = new BigInteger(PRIVATE_KEY, 16);
+    return Credentials.create(ECKeyPair.create(privateKeyInBT));
+  }
+
+  @Bean
+  public NFT nft() {
+    BigInteger gasPrice = Contract.GAS_PRICE;
+    BigInteger gasLimit = Contract.GAS_LIMIT;
+    //StaticGasProvider gasProvider = new StaticGasProvider(gasPrice, gasLimit);
+
+    return NFT.load(CONTRACT_ADDRESS, web3j(), credentials(), gasPrice, gasLimit);
+  }
+}