fix contextID type, move ipni in market

Author: LexLuthr

harmony/harmonydb/sql/20240823-ipni.sql

@@ -2,7 +2,7 @@
 CREATE TABLE ipni (
     order_number BIGSERIAL PRIMARY KEY, -- Unique increasing order number
     ad_cid TEXT NOT NULL,
-    context_id TEXT NOT NULL, -- abi.PieceInfo in Curio
+    context_id BYTEA NOT NULL, -- abi.PieceInfo in Curio
     -- metadata column in not required as Curio only supports one type of metadata(HTTP)
     is_rm BOOLEAN NOT NULL,
 
@@ -39,7 +39,7 @@ CREATE TABLE ipni_head (
 
 CREATE OR REPLACE FUNCTION insert_ad_and_update_head(
     _ad_cid TEXT,
-    _context_id TEXT,
+    _context_id BYTEA,
     _is_rm BOOLEAN,
     _provider TEXT,
     _addresses TEXT,
@@ -71,7 +71,7 @@ CREATE OR REPLACE FUNCTION get_ad_chain(
     _ad_cid TEXT
 ) RETURNS TABLE (
     ad_cid TEXT,
-    context_id TEXT,
+    context_id BYTEA,
     is_rm BOOLEAN,
     previous TEXT,
     provider TEXT,
@@ -98,7 +98,7 @@ END;
 $$ LANGUAGE plpgsql;
 
 -- IPNI pipeline is kept separate from rest for robustness
--- and reuse. This allows for removing, recreating as using CLI.
+-- and reuse. This allows for removing, recreating ads using CLI.
 CREATE TABLE ipni_task (
     sp_id BIGINT NOT NULL,
     sector BIGINT NOT NULL,

lib/ipni/chunker/chunker.go renamed to market/ipni/chunker/chunker.go

@@ -7,15 +7,14 @@ import (
 	"io"
 	"slices"
 
+	"github.com/filecoin-project/curio/market/ipni/ipniculib"
 	lru "github.com/hashicorp/golang-lru/v2"
 	logging "github.com/ipfs/go-log/v2"
 	"github.com/ipld/go-car/v2/index"
 	"github.com/ipld/go-ipld-prime"
 	"github.com/ipld/go-ipld-prime/datamodel"
 	"github.com/ipni/go-libipni/ingest/schema"
 	"github.com/multiformats/go-multihash"
-
-	"github.com/filecoin-project/curio/lib/ipni/ipniculib"
 )
 
 var log = logging.Logger("chunker")

lib/ipni/ipni-provider/ipni-provider.go renamed to market/ipni/ipni-provider/ipni-provider.go

@@ -11,6 +11,8 @@ import (
 	"strings"
 	"time"
 
+	"github.com/filecoin-project/curio/market/ipni/chunker"
+	"github.com/filecoin-project/curio/market/ipni/ipniculib"
 	"github.com/gorilla/mux"
 	lru "github.com/hashicorp/golang-lru/v2"
 	"github.com/ipfs/go-cid"
@@ -35,8 +37,6 @@ import (
 
 	"github.com/filecoin-project/curio/deps"
 	"github.com/filecoin-project/curio/harmony/harmonydb"
-	"github.com/filecoin-project/curio/lib/ipni/chunker"
-	"github.com/filecoin-project/curio/lib/ipni/ipniculib"
 	"github.com/filecoin-project/curio/lib/pieceprovider"
 	"github.com/filecoin-project/curio/lib/storiface"
 	"github.com/filecoin-project/curio/lib/urltomultiaddr"

lib/ipni/ipniculib/ipniculib.go renamed to market/ipni/ipniculib/ipniculib.go

@@ -27,12 +27,12 @@ import (
 	"github.com/filecoin-project/curio/harmony/harmonytask"
 	"github.com/filecoin-project/curio/harmony/resources"
 	"github.com/filecoin-project/curio/lib/ffi"
-	"github.com/filecoin-project/curio/lib/ipni/chunker"
-	"github.com/filecoin-project/curio/lib/ipni/ipniculib"
 	"github.com/filecoin-project/curio/lib/passcall"
 	"github.com/filecoin-project/curio/lib/pieceprovider"
 	"github.com/filecoin-project/curio/lib/storiface"
 	"github.com/filecoin-project/curio/market/indexstore"
+	"github.com/filecoin-project/curio/market/ipni/chunker"
+	"github.com/filecoin-project/curio/market/ipni/ipniculib"
 )
 
 var ilog = logging.Logger("ipni")