content

README

Content Discovery Service

Install the app:

make install

Diagrams:

Basic App

Static Prices

Dynamic Prices

CLI commands:

docker exec -it <container_name> \
  appcli addcontent --id="avatar.png" --title="My Avatar" --author="moti" --filepath="under/the/s3/path/image.png" --recipient_lud16="moti@getalby.com" --price=30

docker exec -it <container_name> \
  appcli updatecontent --id="avatar.png" --title="My Avatar" --author="moti" --filepath="under/the/s3/path/image.png" --recipient_lud16="moti@getalby.com" --price=30

docker exec -it <container_name> \
  appcli removecontent --id="avatar.png"

docker exec -it <container_name> \
  appcli getcontent --id="avatar.png"

Documentation

Index

• type Server
  • func NewServer(ctx context.Context) (*Server, error)
  • func (s *Server) AddContent(ctx context.Context, req *pb.AddContentRequest) (*pb.AddContentResponse, error)
  • func (s *Server) GetContent(ctx context.Context, req *pb.GetContentRequest) (*pb.GetContentResponse, error)
  • func (s *Server) GetPaymentDetails(ctx context.Context, req *pricesrpc.GetPaymentDetailsRequest) (*pricesrpc.GetPaymentDetailsResponse, error)
  • func (s *Server) RemoveContent(ctx context.Context, req *pb.RemoveContentRequest) (*pb.RemoveContentResponse, error)
  • func (s *Server) SetupAWSConfig(ctx context.Context) error
  • func (s *Server) Start() error
  • func (s *Server) Stop() error
  • func (s *Server) UpdateContent(ctx context.Context, req *pb.UpdateContentRequest) (*pb.UpdateContentResponse, error)
• type ServerConfig

Types

type Server

type Server struct {
	DB *db.DB

	*pb.UnimplementedContentServiceServer
	*pricespb.UnimplementedPricesServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context) (*Server, error)

func (*Server) AddContent

func (s *Server) AddContent(ctx context.Context, req *pb.AddContentRequest) (*pb.AddContentResponse, error)

func (*Server) GetContent

func (s *Server) GetContent(ctx context.Context, req *pb.GetContentRequest) (*pb.GetContentResponse, error)

func (*Server) GetPaymentDetails

func (s *Server) GetPaymentDetails(ctx context.Context,
	req *pricesrpc.GetPaymentDetailsRequest) (*pricesrpc.GetPaymentDetailsResponse, error)

func (*Server) RemoveContent

func (s *Server) RemoveContent(ctx context.Context, req *pb.RemoveContentRequest) (*pb.RemoveContentResponse, error)

func (*Server) SetupAWSConfig

func (s *Server) SetupAWSConfig(ctx context.Context) error

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error

func (*Server) UpdateContent

func (s *Server) UpdateContent(ctx context.Context, req *pb.UpdateContentRequest) (*pb.UpdateContentResponse, error)

type ServerConfig

type ServerConfig struct {
	Region   string `env:"AWS_REGION" envDefault:"ap-northeast-1"`
	S3Bucket string `env:"AWS_S3_BUCKET"`
}