feat: on-chain permissioned launchpad

api/launchpad/v1/launchpad.proto

@@ -0,0 +1,135 @@
+syntax = "proto3";
+
+package launchpad.v1;
+option go_package = "./launchpadpb";
+
+service LaunchpadService {
+  rpc UploadMetadatas(UploadMetadatasRequest) returns (UploadMetadatasResponse);
+  rpc CalculateCollectionMerkleRoot(CalculateCollectionMerkleRootRequest) returns (CalculateCollectionMerkleRootResponse);
+  rpc TokenMetadata(TokenMetadataRequest) returns (TokenMetadataResponse);
+  rpc LaunchpadProjects(LaunchpadProjectsRequest) returns (LaunchpadProjectsResponse);
+  rpc LaunchpadProjectById(LaunchpadProjectByIdRequest) returns (LaunchpadProjectByIdResponse);
+  rpc LaunchpadProjectsCounts(LaunchpadProjectsCountsRequest) returns (LaunchpadProjectsCountsResponse);
+}
+
+enum Sort {
+  SORT_UNSPECIFIED = 0;
+  SORT_COLLECTION_NAME = 1;
+}
+
+enum SortDirection {
+  SORT_DIRECTION_UNSPECIFIED = 0;
+  SORT_DIRECTION_ASCENDING = 1;
+  SORT_DIRECTION_DESCENDING = 2;
+}
+
+enum Status {
+  STATUS_UNSPECIFIED = 0;
+  STATUS_INCOMPLETE = 1;
+  STATUS_COMPLETE = 2;
+  STATUS_REVIEWING = 3;
+  STATUS_CONFIRMED = 4;
+}
+
+// -------------------------------
+
+message LaunchpadProjectsRequest {
+  string network_id = 1;
+  int32 limit = 2;
+  int32 offset = 3;
+  Sort sort = 4;
+  SortDirection sort_direction = 5;
+  Status status = 6;
+  string creator_id = 7;
+}
+
+message LaunchpadProjectsResponse {
+  repeated LaunchpadProject projects = 1;
+}
+
+message LaunchpadProjectByIdRequest {
+  string network_id = 1;
+  string project_id = 2;
+}
+
+message LaunchpadProjectByIdResponse {
+  LaunchpadProject project = 1;
+}
+
+message UploadMetadatasRequest {
+  string sender = 1;
+  string network_id = 2;
+  string project_id = 3;
+  repeated Metadata metadatas = 4;
+  string pinata_jwt = 5;
+}
+
+message UploadMetadatasResponse {
+  string merkle_root = 1;
+}
+
+message CalculateCollectionMerkleRootRequest {
+  string sender = 1;
+  repeated Metadata metadatas = 2;
+}
+
+message CalculateCollectionMerkleRootResponse {
+  string merkle_root = 1;
+}
+
+message TokenMetadataRequest {
+  string sender = 1;
+  string network_id = 2;
+  string project_id = 3;
+  uint32 token_id = 4;
+}
+
+message TokenMetadataResponse {
+  string merkle_root = 1;
+  Metadata metadata = 2;
+  repeated string merkle_proof = 3;
+}
+
+message LaunchpadProjectsCountsRequest {
+  string network_id = 1;
+}
+
+message LaunchpadProjectsCountsResponse {
+  repeated StatusCount status_counts = 1;
+}
+
+// -------------------------------
+
+message StatusCount {
+  Status status = 1;
+  uint32 count = 2;
+}
+
+message LaunchpadProject {
+  string id = 1;
+  string network_id = 2;
+  string creator_id = 3;
+  string collection_data = 4;
+  Status status = 5;
+  string proposal_id = 6;
+}
+
+message Metadata {
+  optional string image = 1;
+  optional string image_data = 2;
+  optional string external_url = 3;
+  optional string description = 4;
+  optional string name = 5;
+  repeated Trait attributes = 6;
+  optional string background_color = 7;
+  optional string animation_url = 8;
+  optional string youtube_url = 9;
+  optional uint64 royalty_percentage = 10;
+  optional string royalty_payment_address = 11;
+}
+
+message Trait {
+  optional string display_type = 1;
+  string trait_type = 2;
+  string value = 3;
+}

buf.gen.yaml

@@ -2,6 +2,8 @@ version: v1
 plugins:
   - name: go
     out: go/pkg
+  - plugin: buf.build/community/neoeinstein-prost:v0.3.1
+    out: rust/apipb/src
   - name: go-grpc
     out: go/pkg
   - name: ts

build_release.sh

@@ -0,0 +1,10 @@
+# Optimized builds
+# docker run --rm -v "$(pwd)/rust":/code \
+#   --mount type=volume,source="$(basename "$(pwd)")_cache",target=/code/target \
+#   --mount type=volume,source=registry_cache,target=/usr/local/cargo/registry \
+#   cosmwasm/workspace-optimizer-arm64:0.15.0
+
+docker run --rm -v "$(pwd)":/code \
+  --mount type=volume,source="$(basename "$(pwd)")_cache",target=/target \
+  --mount type=volume,source=registry_cache,target=/usr/local/cargo/registry \
+  cosmwasm/rust-optimizer-arm64:0.15.0 ./rust/cw-contracts/nft-launchpad

go.mod

@@ -18,6 +18,8 @@ require (
 	github.com/go-co-op/gocron v1.18.0
 	github.com/gorilla/websocket v1.5.0
 	github.com/improbable-eng/grpc-web v0.15.0
+	github.com/ipfs/boxo v0.8.0
+	github.com/ipfs/go-cid v0.4.1
 	github.com/jackc/pgx/v5 v5.3.0
 	github.com/joho/godotenv v1.5.1
 	github.com/lib/pq v1.10.7
@@ -168,9 +170,8 @@ require (
 	github.com/holiman/uint256 v1.2.2-0.20230321075855-87b91420868c // indirect
 	github.com/huandu/skiplist v1.2.0 // indirect
 	github.com/inconshreveable/mousetrap v1.1.0 // indirect
-	github.com/ipfs/boxo v0.8.0 // indirect
-	github.com/ipfs/go-cid v0.4.1 // indirect
 	github.com/ipfs/go-ipfs-api v0.6.0 // indirect
+	github.com/ipfs/go-log/v2 v2.5.1 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a // indirect
 	github.com/jhump/protoreflect v1.15.1 // indirect

go.sum

@@ -852,6 +852,8 @@ github.com/ipfs/go-cid v0.4.1 h1:A/T3qGvxi4kpKWWcPC/PgbvDA2bjVLO7n4UeVwnbs/s=
 github.com/ipfs/go-cid v0.4.1/go.mod h1:uQHwDeX4c6CtyrFwdqyhpNcxVewur1M7l7fNU7LKwZk=
 github.com/ipfs/go-ipfs-api v0.6.0 h1:JARgG0VTbjyVhO5ZfesnbXv9wTcMvoKRBLF1SzJqzmg=
 github.com/ipfs/go-ipfs-api v0.6.0/go.mod h1:iDC2VMwN9LUpQV/GzEeZ2zNqd8NUdRmWcFM+K/6odf0=
+github.com/ipfs/go-log/v2 v2.5.1 h1:1XdUzF7048prq4aBjDQQ4SL5RxftpRGdXhNRwKSAlcY=
+github.com/ipfs/go-log/v2 v2.5.1/go.mod h1:prSpmC1Gpllc9UYWxDiZDreBYw7zp4Iqp1kOLU9U5UI=
 github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
 github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
 github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a h1:bbPeKD0xmW/Y25WS6cokEszi5g+S0QxI/d45PkRi7Nk=

go/cmd/check-pin/main.go

@@ -0,0 +1,29 @@
+package main
+
+import (
+	"context"
+	"fmt"
+
+	remoteClient "github.com/ipfs/boxo/pinning/remote/client"
+)
+
+func main() {
+	// url := "https://nft.storage"
+	url := "https://api.pinata.cloud/psa"
+	// bearerToken := "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiJkaWQ6ZXRocjoweDljQzdjNTI2QUMyOGQ0MDZFOTk3Zjg5RjVEODY1NDkzYzQyZjhFMzYiLCJpc3MiOiJuZnQtc3RvcmFnZSIsImlhdCI6MTcxMzg1NTY3Mjc4NiwibmFtZSI6InBpbm5pbmcifQ.yGO_AZl91Ail71u0AdNoXE7G9NmEnxQ_vjq8uh4Pxn0"
+	bearerToken := "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VySW5mb3JtYXRpb24iOnsiaWQiOiIwMjJlZjcyOC0xMGJjLTQ2ZmMtYjI1NC02M2Y2MWM0N2YyZjAiLCJlbWFpbCI6InRyb25naGlldS5oYUBnbWFpbC5jb20iLCJlbWFpbF92ZXJpZmllZCI6dHJ1ZSwicGluX3BvbGljeSI6eyJyZWdpb25zIjpbeyJpZCI6IkZSQTEiLCJkZXNpcmVkUmVwbGljYXRpb25Db3VudCI6MX1dLCJ2ZXJzaW9uIjoxfSwibWZhX2VuYWJsZWQiOmZhbHNlLCJzdGF0dXMiOiJBQ1RJVkUifSwiYXV0aGVudGljYXRpb25UeXBlIjoic2NvcGVkS2V5Iiwic2NvcGVkS2V5S2V5IjoiMTgwNDY2ZTA5YjE0ZjBiODg1M2YiLCJzY29wZWRLZXlTZWNyZXQiOiI1NGEwMzRiNzJiMzk0NzM2MzQ1NTZlY2I5OGQzNmI4Y2Q2NmM2ZTM2MWNhM2I4MDVhZTMyZGJlYTQwZTRlZDY1IiwiaWF0IjoxNzEzODYzMzc5fQ.tuSSi9dSjSO2IOTlNsU6kgWxSMIG5N6mlYzC3VuSkTA"
+
+	client := remoteClient.NewClient(url, bearerToken)
+	ctx := context.Background()
+
+	data, err := client.LsSync(ctx)
+
+	// myCid, err := cid.Decode("Qmf9eHWdSY3v2cwm4ckTcVj59pXV7QSiU6zfeUwXnNx1Me")
+	// fmt.Println("myCid:", myCid, " - err:", err)
+
+	// status, err := client.Add(ctx, myCid)
+	// fmt.Println("status:", status, " - err:", err)
+
+	fmt.Println(err)
+	fmt.Println(data)
+}

go/cmd/teritori-launchpad-backend/main.go

@@ -0,0 +1,146 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"fmt"
+	"net"
+	"net/http"
+	"os"
+
+	"github.com/TERITORI/teritori-dapp/go/internal/indexerdb"
+	"github.com/TERITORI/teritori-dapp/go/pkg/launchpad"
+	"github.com/TERITORI/teritori-dapp/go/pkg/launchpadpb"
+	"github.com/TERITORI/teritori-dapp/go/pkg/networks"
+	"github.com/improbable-eng/grpc-web/go/grpcweb"
+	"github.com/peterbourgon/ff/v3"
+	"github.com/pkg/errors"
+	"go.uber.org/zap"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/reflection"
+)
+
+// FIXME: for now, I dont find how to add reflection on grpc wrapped by http server
+// so to enable Postman reflection, I'm using this DEBUG const to switch on/off that capacity
+const DEBUG = false
+
+func main() {
+	fs := flag.NewFlagSet("teritori-dapp-backend", flag.ContinueOnError)
+	var (
+		enableTls       = flag.Bool("enable_tls", false, "Use TLS - required for HTTP2.")
+		tlsCertFilePath = flag.String("tls_cert_file", "../../misc/localhost.crt", "Path to the CRT/PEM file.")
+		tlsKeyFilePath  = flag.String("tls_key_file", "../../misc/localhost.key", "Path to the private key file.")
+		dbHost          = fs.String("db-indexer-host", "", "host postgreSQL database")
+		dbPort          = fs.String("db-indexer-port", "", "port for postgreSQL database")
+		dbPass          = fs.String("postgres-password", "", "password for postgreSQL database")
+		dbName          = fs.String("database-name", "", "database name for postgreSQL")
+		dbUser          = fs.String("postgres-user", "", "username for postgreSQL")
+		networksFile    = fs.String("networks-file", "networks.json", "path to networks config file")
+		pinataJWT       = fs.String("pinata-jwt", "", "Pinata admin JWT token")
+	)
+	if err := ff.Parse(fs, os.Args[1:],
+		ff.WithEnvVars(),
+		ff.WithIgnoreUndefined(true),
+		ff.WithConfigFile(".env"),
+		ff.WithConfigFileParser(ff.EnvParser),
+		ff.WithAllowMissingConfigFile(true),
+	); err != nil {
+		panic(errors.Wrap(err, "failed to parse flags"))
+	}
+
+	logger, err := zap.NewDevelopment()
+	if err != nil {
+		panic(errors.Wrap(err, "failed to create logger"))
+	}
+
+	if *pinataJWT == "" {
+		logger.Warn("missing PINATA_JWT, feed pinning will be disabled")
+	}
+
+	// load networks
+	networksBytes, err := os.ReadFile(*networksFile)
+	if err != nil {
+		panic(errors.Wrap(err, "failed to read networks config file"))
+	}
+	netstore, err := networks.UnmarshalNetworkStore(networksBytes)
+	if err != nil {
+		panic(errors.Wrap(err, "failed to unmarshal networks config"))
+	}
+
+	var launchpadModels = []interface{}{
+		// users
+		&indexerdb.User{},
+
+		// launchpad
+		&LaunchpadProject{},
+		&LaunchpadToken{},
+	}
+
+	dataConnexion := fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%s",
+		*dbHost, *dbUser, *dbPass, *dbName, *dbPort)
+	launchpadDB, err := indexerdb.NewPostgresDB(dataConnexion)
+
+	if err != nil {
+		panic(errors.Wrap(err, "failed to access db"))
+	}
+	launchpadDB.AutoMigrate(launchpadModels...)
+
+	port := 9080
+	if *enableTls {
+		port = 9081
+	}
+
+	launchpadSvc := launchpad.NewLaunchpadService(context.Background(), &launchpad.Config{
+		Logger:       logger,
+		IndexerDB:    launchpadDB,
+		PinataJWT:    *pinataJWT,
+		NetworkStore: netstore,
+	})
+
+	server := grpc.NewServer()
+	launchpadpb.RegisterLaunchpadServiceServer(server, launchpadSvc)
+
+	if DEBUG {
+		lis, err := net.Listen("tcp", fmt.Sprintf(":%d", port))
+		if err != nil {
+			panic(errors.Wrapf(err, "[DEBUG] failed to listen on port %d", port))
+		}
+
+		reflection.Register(server)
+
+		logger.Info(fmt.Sprintf("[DEBUG] gRPC server listening at: %s", lis.Addr().String()))
+		if err := server.Serve(lis); err != nil {
+			panic(errors.Errorf("failed to serve: %v", err))
+		}
+	}
+
+	wrappedServer := grpcweb.WrapServer(server,
+		grpcweb.WithWebsockets(true),
+		grpcweb.WithWebsocketOriginFunc(func(*http.Request) bool { return true }))
+
+	handler := func(resp http.ResponseWriter, req *http.Request) {
+		resp.Header().Set("Access-Control-Allow-Origin", "*")
+		resp.Header().Set("Access-Control-Allow-Headers", "*")
+		logger.Debug(fmt.Sprintf("Request: %v", req))
+		wrappedServer.ServeHTTP(resp, req)
+	}
+
+	httpServer := http.Server{
+		Addr:    fmt.Sprintf(":%d", port),
+		Handler: http.HandlerFunc(handler),
+	}
+
+	reflection.Register(server)
+
+	logger.Info(fmt.Sprintf("Starting server. http port: %d, with TLS: %v", port, *enableTls))
+
+	if *enableTls {
+		if err := httpServer.ListenAndServeTLS(*tlsCertFilePath, *tlsKeyFilePath); err != nil {
+			panic(fmt.Errorf("failed starting http2 server: %v", err))
+		}
+	} else {
+		if err := httpServer.ListenAndServe(); err != nil {
+			panic(fmt.Errorf("failed starting http server: %v", err))
+		}
+	}
+}