util

Mar 8, 2023

Changes in this version

+ func NewBinder(log *zap.SugaredLogger) binder

+ func ToMultiAddress(addr string) (multiaddr.Multiaddr, error)

+ func ToMultiAddresses(addrs []string) ([]multiaddr.Multiaddr, error)

Jan 30, 2023

Changes in this version

type AuthToken

+ IsSession bool

Jan 19, 2023

Changes in this version

+ func CacheKey(c echo.Context, u *User, tags ...string) string

+ func WithUser(f func(echo.Context, *User) error) func(echo.Context) error

Jan 10, 2023

Changes in this version

+ const ERR_CONTENT_IN_COLLECTION

type ContentInCollection

+ Overwrite bool

Dec 17, 2022

Changes in this version

+ type DbAddrInfo struct

+ AddrInfo peer.AddrInfo

+ func (dba DbAddrInfo) Scan(v interface{}) error

+ func (dba DbAddrInfo) Value() (driver.Value, error)

Dec 15, 2022

Changes in this version

type Content

+ DealStatus string

Dec 14, 2022

Changes in this version

+ func ConfigureRateLimiter(rateLimit rate.Limit) middleware.RateLimiterConfig

type Content

+ PinningStatus string

Dec 11, 2022

Changes in this version

+ const DefaultBatchSize

+ func FindAndProcessLargeRequests(db *gorm.DB, fc func(tx *gorm.DB, batch int) error, dest interface{}, ...) (tx *gorm.DB)

Dec 10, 2022

Changes in this version

+ const ERR_BAD_REQUEST

+ const ERR_INTERNAL_SERVER

+ func OpenApiMiddleware(log *zap.SugaredLogger) echo.MiddlewareFunc

+ func TracingMiddleware(tcr trace.Tracer) echo.MiddlewareFunc

+ func WithMultipartFormDataChecker(next echo.HandlerFunc) echo.HandlerFunc

Nov 26, 2022

Changes in this version

+ const ERR_INVALID_MINER_CLAIM_ASK_VERIFIED_PRICE_IS_NOT_ZERO

+ const ERR_INVALID_MINER_CLAIM_NO_ASK

+ const ERR_INVALID_MINER_CLAIM_NO_MULTI_ADDR

+ const ERR_INVALID_MINER_CLAIM_NO_PEER_ID

+ const ERR_INVALID_MINER_CLAIM_NO_POWER

+ const ERR_INVALID_MINER_CLAIM_POWER_BELOW_1TIB

+ const ERR_INVALID_MINER_CLAIM_SIG

+ const ERR_INVALID_MINER_SETUP

+ func CreateDwebRetrievalURL(cid string) string

+ func CreateEstuaryRetrievalURL(cid string) string

+ func DumpBlockstoreTo(ctx context.Context, tc trace.Tracer, from, to blockstore.Blockstore) error

type ContentAddResponse

+ EstuaryRetrievalURL string

+ type TrackingBlockstore struct

+ func NewTrackingBlockstore(bs blockstore.Blockstore, db *gorm.DB) *TrackingBlockstore

+ func (tbs *TrackingBlockstore) AllKeysChan(context.Context) (<-chan cid.Cid, error)

+ func (tbs *TrackingBlockstore) DeleteBlock(ctx context.Context, _ cid.Cid) error

+ func (tbs *TrackingBlockstore) Get(ctx context.Context, c cid.Cid) (blocks.Block, error)

+ func (tbs *TrackingBlockstore) GetCounts(objects []Object) ([]int, error)

+ func (tbs *TrackingBlockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)

+ func (tbs *TrackingBlockstore) Has(ctx context.Context, c cid.Cid) (bool, error)

+ func (tbs *TrackingBlockstore) HashOnRead(hashOnRead bool)

+ func (tbs *TrackingBlockstore) LastAccess(ctx context.Context, c cid.Cid) (time.Time, error)

+ func (tbs *TrackingBlockstore) Put(ctx context.Context, blk blocks.Block) error

+ func (tbs *TrackingBlockstore) PutMany(ctx context.Context, blks []blocks.Block) error

+ func (tbs *TrackingBlockstore) SetCidReqFunc(f func(context.Context, cid.Cid) (blocks.Block, error))

+ func (tbs *TrackingBlockstore) Under() blockstore.Blockstore

Nov 17, 2022

Changes in this version

+ const ERR_AUTH_MISSING_BEARER_DETAILS

+ const ERR_AUTH_MISSING_DETAILS

+ const ERR_INVALID_AUTH_DETAILS

+ func GetTokenHash(token string) string

type AuthToken

+ Label string

+ TokenHash string

Oct 22, 2022

Changes in this version

+ const ERR_INVALID_FILTER

+ const ERR_RECORD_NOT_FOUND

+ const ERR_UNSUPPORTED_CONTENT_TYPE

+ const ERR_VALUE_REQUIRED

+ func GetPasswordHashBase(password, salt string) string

+ func GetPasswordHashBase64(password, salt string) string

+ func JSONPayloadMiddleware(next echo.HandlerFunc) echo.HandlerFunc

+ type AuthToken struct

+ Expiry time.Time

+ Token string

+ UploadOnly bool

+ User uint

+ type Binder struct

+ func (b Binder) Bind(i interface{}, c echo.Context) error

type Content

+ func GetContent(contentid string, db *gorm.DB, u *User) (Content, error)

+ type InviteCode struct

+ ClaimedBy uint

+ Code string

+ CreatedBy uint

+ type User struct

+ Address DbAddr

+ AuthToken AuthToken

+ DID string

+ Flags int

+ PassHash string

+ Perm int

+ Salt string

+ StorageDisabled bool

+ UUID string

+ UserEmail string

+ Username string

+ func (u *User) FlagSplitContent() bool

Sep 12, 2022

Changes in this version

+ func CanRestartTransfer(st *filclient.ChannelState) bool

+ func TransferFailed(st *filclient.ChannelState) (bool, string)

type Content

+ Name string

type ContentAddIpfsBody

+ Name string

Jul 29, 2022

Changes in this version

+ const ERR_CONTENT_LENGTH_REQUIRED

+ const ERR_INVALID_QUERY_PARAM_VALUE

+ func CreateRetrievalURL(cid string) string

+ func GetPasswordHash(password, salt string) string

+ func WithContentLengthCheck(f func(echo.Context) error) func(echo.Context) error

+ type CarObject struct

+ Cid cid.Cid

+ Size uint64

+ type Content struct

+ Active bool

+ Aggregate bool

+ AggregatedIn uint

+ Cid DbCID

+ CreatedAt time.Time

+ DagSplit bool

+ DeletedAt gorm.DeletedAt

+ Description string

+ Failed bool

+ Filename string

+ ID uint

+ Location string

+ Offloaded bool

+ Origins string

+ PinMeta string

+ Pinning bool

+ Replace bool

+ Replication int

+ Size int64

+ SplitFrom uint

+ Type ContentType

+ UpdatedAt time.Time

+ UserID uint

type ContentAddResponse

+ RetrievalURL string

type ContentCreateBody

+ Filename string

+ type ContentWithPath struct

+ Path string

+ type ObjRef struct

+ Content uint

+ ID uint

+ Object uint

+ Offloaded uint

type Object

+ ID uint

+ LastAccess time.Time

+ Reads int

Jul 21, 2022

Changes in this version

+ func ErrorIfContentAddingDisabled(isContentAddingDisabled bool) error

type ContentInCollection

+ CollectionDir string

Jul 18, 2022

Changes in this version

+ const ContentLocationLocal

+ var FlagLogLevel = &cli.StringFlag

+ var LogLevel string

+ func IsCollectionOwner(uID, entityID uint) error

+ func IsContentOwner(uID, entityID uint) error

Jun 24, 2022

Changes in this version

+ const ERR_CONTENT_NOT_FOUND

+ const ERR_INVALID_PINNING_STATUS

+ const ERR_PEERING_PEERS_ADD_ERROR

+ const ERR_PEERING_PEERS_REMOVE_ERROR

+ const ERR_PEERING_PEERS_START_ERROR

+ const ERR_PEERING_PEERS_STOP_ERROR

+ type GenericResponse struct

+ Message string

type HttpError

+ Reason string

+ type HttpErrorResponse struct

+ Error HttpError

+ type PeeringPeerAddMessage struct

+ Message string

+ PeersAdd []peering.PeeringPeer

+ type PeeringPeerRemoveMessage struct

+ Message string

+ PeersRemove []peer.ID

Jun 8, 2022

Changes in this version

+ const DefaultContentSizeLimit

+ const ERR_AUTH_MISSING

+ const ERR_AUTH_MISSING_BEARER

+ const ERR_CONTENT_ADDING_DISABLED

+ const ERR_CONTENT_SIZE_OVER_LIMIT

+ const ERR_INVALID_AUTH

+ const ERR_INVALID_INPUT

+ const ERR_INVALID_INVITE

+ const ERR_INVALID_PASSWORD

+ const ERR_INVALID_TOKEN

+ const ERR_INVITE_ALREADY_USED

+ const ERR_MINER_NOT_OWNED

+ const ERR_NOT_AUTHORIZED

+ const ERR_TOKEN_EXPIRED

+ const ERR_USERNAME_TAKEN

+ const ERR_USER_CREATION_FAILED

+ const ERR_USER_NOT_FOUND

+ const ERR_WRONG_AUTH_FORMAT

+ const PermLevelAdmin

+ const PermLevelUpload

+ const PermLevelUser

+ var DefaultHashFunction = uint64(mh.SHA2_256)

+ func AppVersionMiddleware(appVersion string) echo.MiddlewareFunc

+ func CalculateCarSize(data cid.Cid, objects []Object) (uint64, error)

+ func CidIsUnwalkable(c cid.Cid) bool

+ func DirsFromPath(collectionPath string, filename string) ([]string, error)

+ func EnsurePathIsLinked(dirs []string, rootNode *merkledag.ProtoNode, ds format.DAGService) (*merkledag.ProtoNode, error)

+ func ErrorHandler(err error, ctx echo.Context)

+ func ExtractAuth(c echo.Context) (string, error)

+ func FilterUnwalkableLinks(links []*ipld.Link) []*ipld.Link

+ func ImportFile(dserv ipld.DAGService, fi io.Reader) (ipld.Node, error)

+ func ParseDealLabel(s string) (cid.Cid, error)

+ func SetupDatabase(dbval string) (*gorm.DB, error)

+ func TransferTerminated(st *filclient.ChannelState) bool

+ func TryExtractFSNode(nd ipld.Node) (*unixfs.FSNode, error)

+ func ValidatePeerInfo(peerID string, addresses []string) (*peer.AddrInfo, error)

+ type AutoretrieveInitResponse struct

+ AddrInfo *peer.AddrInfo

+ Handle string

+ LastConnection time.Time

+ Token string

+ type AutoretrieveListResponse struct

+ AddrInfo *peer.AddrInfo

+ Handle string

+ LastConnection time.Time

+ type ChanTrack struct

+ Dbid uint

+ Last *filclient.ChannelState

+ type ContentAddIpfsBody struct

+ Filename string

+ Peers []string

+ Root string

+ type ContentAddResponse struct

+ Cid string

+ EstuaryId uint

+ Providers []string

+ type ContentCreateBody struct

+ Location string

+ Name string

+ Root string

+ Type ContentType

+ type ContentCreateResponse struct

+ ID uint

+ type ContentInCollection struct

+ CollectionID string

+ CollectionPath string

+ type ContentType int64

+ const Directory

+ const File

+ const Unknown

+ func FindCIDType(ctx context.Context, root cid.Cid, dserv ipld.NodeGetter) (contentType ContentType)

+ type DbAddr struct

+ Addr address.Address

+ func (dba *DbAddr) Scan(v interface{}) error

+ func (dba DbAddr) Value() (driver.Value, error)

+ type DbCID struct

+ CID cid.Cid

+ func (dbc *DbCID) Scan(v interface{}) error

+ func (dbc *DbCID) UnmarshalJSON(b []byte) error

+ func (dbc DbCID) MarshalJSON() ([]byte, error)

+ func (dbc DbCID) Value() (driver.Value, error)

+ type HeartbeatAutoretrieveResponse struct

+ AddrInfo *peer.AddrInfo

+ Handle string

+ LastConnection time.Time

+ type HttpError struct

+ Code int

+ Details string

+ Message string

+ func (he HttpError) Error() string

+ type InitShuttleResponse struct

+ Handle string

+ Token string

+ type Object struct

+ Cid cid.Cid

+ Size uint64

+ type RetrievalFailureRecord struct

+ Cid DbCID

+ Content uint

+ Message string

+ Miner string

+ Phase string

+ type RetrievalProgress struct

+ EndErr error

+ Wait chan struct{}

+ type Shuttle struct

+ AddPinLk sync.Mutex

+ Api api.Gateway

+ AuthCache *lru.TwoQueueCache

+ CommpMemo *memo.Memoizer

+ DB *gorm.DB

+ Dev bool

+ DisableLocalAdding bool

+ EstuaryHost string

+ Filc *filclient.FilClient

+ GwayHandler *gateway.GatewayHandler

+ Hostname string

+ InflightCids map[cid.Cid]uint

+ InflightCidsLk sync.Mutex

+ Node *node.Node

+ Outgoing chan *drpc.Message

+ PinMgr *pinner.PinManager

+ Private bool

+ RetrLk sync.Mutex

+ RetrievalsInProgress map[uint]*RetrievalProgress

+ ShuttleHandle string

+ ShuttleToken string

+ SplitLk sync.Mutex

+ SplitsInProgress map[uint]bool

+ StagingMgr *stagingbs.StagingBSMgr

+ TcLk sync.Mutex

+ Tracer trace.Tracer

+ TrackingChannels map[string]*ChanTrack

+ type ShuttleCreateContentBody struct

+ Collections []string

+ DagSplitRoot uint

+ Location string

+ Name string

+ Root cid.Cid

+ User uint

+ type ShuttleListResponse struct

+ AddrInfo *peer.AddrInfo

+ Address address.Address

+ Handle string

+ Hostname string

+ LastConnection time.Time

+ Online bool

+ StorageStats *ShuttleStorageStats

+ Token string

+ type ShuttleStorageStats struct

+ BlockstoreFree uint64

+ BlockstoreSize uint64

+ PinCount int64

+ PinQueueLength int64

+ type UserSettings struct

+ ContentAddingDisabled bool

+ DealDuration int

+ DealMakingDisabled bool

+ FileStagingThreshold int64

+ Flags int

+ MaxStagingWait time.Duration

+ Replication int

+ UploadEndpoints []string

+ Verified bool

+ type ViewerResponse struct

+ Address string

+ AuthExpiry time.Time

+ ID uint

+ Miners []string

+ Perms int

+ Settings UserSettings

+ Username string