firesert

README

firesert

Create Go microservices that receive Pub/Sub push messages and insert their data into Firestore collections.

Very easy to use, create a working service by adding just one line of code to your main method:

firesert.Run()

Examples

Try working examples of firesert here

Getting started

Create a new Go project

mkdir firesert-example
cd firesert-example
go mod init firesert/example

Get firesert

go get github.com/jonnyorman/firesert

Add a main.go file with the following

package main

import "github.com/jonnyorman/firesert"

func main() {
	firesert.Run()
}

Add a firesert-config.json file with the following

{
    "projectID": "your-firebase-project",
    "collectionName": "FirestoreCollection"
}

Tidy and run with access to a Firebase project or emulator

    go mod tidy
    go run .

Submit a POST to the service with a Pub/Sub push body. You will see the data get inserted in the FirestoreCollection collection in your Firestore.

You can also create a struct with the data you want to insert into Firestore. Create a struct and use it:

package main

import "github.com/jonnyorman/firesert"

type DocumentModel struct {
	Prop1 string
	Prop2 int
}

func main() {
	firesert.RunTyped[DocumentModel]()
}

Documentation

Index

• func Run()
• func RunTyped[T any]()
• type Application
  • func BuildApplication[T any]() Application
  • func NewApplication(router *gin.Engine) *Application
  • func (this Application) Run()
• type Configuration
  • func NewConfiguration(projectID string, collectionName string) *Configuration
• type ConfigurationCreator
• type ConfigurationFilePathProvider
  • func NewConfigurationFilePathProvider(fileName string) *ConfigurationFilePathProvider
  • func (this ConfigurationFilePathProvider) Get() string
• type ConfigurationJsonFileReader
  • func NewConfigurationJsonFileReader(filePathProvider FilePathProvider) *ConfigurationJsonFileReader
  • func (this ConfigurationJsonFileReader) Read() []byte
• type ConfigurationLoader
• type DataDeserialiser
• type DataInserter
• type DataReader
• type FilePathProvider
• type FileReader
• type FirestoreDataInserter
  • func NewFirestoreDataInserter[T any](configuration Configuration) *FirestoreDataInserter[T]
  • func (this FirestoreDataInserter[T]) Insert(data T)
• type GinPubSubBodyReader
  • func NewGinPubSubBodyReader(reader Reader, pubSubBodyDeserialiser DataDeserialiser[PubSubBody]) *GinPubSubBodyReader
  • func (this GinPubSubBodyReader) Read(ginContext *gin.Context) PubSubBody
• type GinRouterBuilder
  • func NewGinRouterBuilder[T any](requestHandler RequestHandler[T]) *GinRouterBuilder[T]
  • func (this GinRouterBuilder[T]) Build() *gin.Engine
• type HttpRequestBodyDataReader
  • func NewHttpRequestBodyDataReader[T any](pubSubBodyReader PubSubBodyReader, dataDeserialiser DataDeserialiser[T]) *HttpRequestBodyDataReader[T]
  • func (this HttpRequestBodyDataReader[T]) Read(ginContext *gin.Context) T
• type IoReaderGenerator
• type IoutilReader
  • func (this IoutilReader) Read(ioReader io.Reader) []byte
• type JsonConfigurationCreator
  • func (this JsonConfigurationCreator) Create(configurationJson []byte) Configuration
• type JsonConfigurationLoader
  • func NewJsonConfigurationLoader(fileReader FileReader, configuratoinCreator ConfigurationCreator) *JsonConfigurationLoader
  • func (this JsonConfigurationLoader) Load() Configuration
• type JsonDataDeserialiser
  • func (this JsonDataDeserialiser[T]) Deserialise(data []byte) T
• type PubSubBody
• type PubSubBodyReader
• type PubSubPushRequestHandler
  • func (this PubSubPushRequestHandler[T]) Handle(ginContext *gin.Context)
• type Reader
• type RequestHandler
• type RouterBuilder

Functions

func Run

func Run()

func RunTyped

func RunTyped[T any]()

Types

type Application

type Application struct {
	// contains filtered or unexported fields
}

func BuildApplication

func BuildApplication[T any]() Application

func NewApplication

func NewApplication(router *gin.Engine) *Application

func (Application) Run

func (this Application) Run()

type Configuration

type Configuration struct {
	ProjectID      string
	CollectionName string
}

func NewConfiguration

func NewConfiguration(projectID string, collectionName string) *Configuration

type ConfigurationCreator

type ConfigurationCreator interface {
	Create(configurationJson []byte) Configuration
}

type ConfigurationFilePathProvider

type ConfigurationFilePathProvider struct {
	// contains filtered or unexported fields
}

func NewConfigurationFilePathProvider

func NewConfigurationFilePathProvider(fileName string) *ConfigurationFilePathProvider

func (ConfigurationFilePathProvider) Get

func (this ConfigurationFilePathProvider) Get() string

type ConfigurationJsonFileReader

type ConfigurationJsonFileReader struct {
	// contains filtered or unexported fields
}

func NewConfigurationJsonFileReader

func NewConfigurationJsonFileReader(filePathProvider FilePathProvider) *ConfigurationJsonFileReader

func (ConfigurationJsonFileReader) Read

func (this ConfigurationJsonFileReader) Read() []byte

type ConfigurationLoader

type ConfigurationLoader interface {
	Load() Configuration
}

type DataDeserialiser

type DataDeserialiser[T any] interface {
	Deserialise(data []byte) T
}

type DataInserter

type DataInserter[T any] interface {
	Insert(data T)
}

type DataReader

type DataReader[T any] interface {
	Read(ginContext *gin.Context) T
}

type FilePathProvider

type FilePathProvider interface {
	Get() string
}

type FileReader

type FileReader interface {
	Read() []byte
}

type FirestoreDataInserter

type FirestoreDataInserter[T any] struct {
	// contains filtered or unexported fields
}

func NewFirestoreDataInserter

func NewFirestoreDataInserter[T any](configuration Configuration) *FirestoreDataInserter[T]

func (FirestoreDataInserter[T]) Insert

func (this FirestoreDataInserter[T]) Insert(data T)

type GinPubSubBodyReader

type GinPubSubBodyReader struct {
	// contains filtered or unexported fields
}

func NewGinPubSubBodyReader

func NewGinPubSubBodyReader(
	reader Reader,
	pubSubBodyDeserialiser DataDeserialiser[PubSubBody]) *GinPubSubBodyReader

func (GinPubSubBodyReader) Read

func (this GinPubSubBodyReader) Read(ginContext *gin.Context) PubSubBody

type GinRouterBuilder

type GinRouterBuilder[T any] struct {
	// contains filtered or unexported fields
}

func NewGinRouterBuilder

func NewGinRouterBuilder[T any](requestHandler RequestHandler[T]) *GinRouterBuilder[T]

func (GinRouterBuilder[T]) Build

func (this GinRouterBuilder[T]) Build() *gin.Engine

type HttpRequestBodyDataReader

type HttpRequestBodyDataReader[T any] struct {
	// contains filtered or unexported fields
}

func NewHttpRequestBodyDataReader

func NewHttpRequestBodyDataReader[T any](
	pubSubBodyReader PubSubBodyReader,
	dataDeserialiser DataDeserialiser[T]) *HttpRequestBodyDataReader[T]

func (HttpRequestBodyDataReader[T]) Read

func (this HttpRequestBodyDataReader[T]) Read(ginContext *gin.Context) T

type IoReaderGenerator

type IoReaderGenerator interface {
	Generate(payload string) io.Reader
}

type IoutilReader

type IoutilReader struct{}

func (IoutilReader) Read

func (this IoutilReader) Read(ioReader io.Reader) []byte

type JsonConfigurationCreator

type JsonConfigurationCreator struct{}

func (JsonConfigurationCreator) Create

func (this JsonConfigurationCreator) Create(configurationJson []byte) Configuration

type JsonConfigurationLoader

type JsonConfigurationLoader struct {
	// contains filtered or unexported fields
}

func NewJsonConfigurationLoader

func NewJsonConfigurationLoader(
	fileReader FileReader,
	configuratoinCreator ConfigurationCreator) *JsonConfigurationLoader

func (JsonConfigurationLoader) Load

func (this JsonConfigurationLoader) Load() Configuration

type JsonDataDeserialiser

type JsonDataDeserialiser[T any] struct{}

func (JsonDataDeserialiser[T]) Deserialise

func (this JsonDataDeserialiser[T]) Deserialise(data []byte) T

type PubSubBody

type PubSubBody struct {
	Message      pubsub.Message
	Subscription string
}

type PubSubBodyReader

type PubSubBodyReader interface {
	Read(ginContext *gin.Context) PubSubBody
}

type PubSubPushRequestHandler

type PubSubPushRequestHandler[T any] struct {
	// contains filtered or unexported fields
}

func (PubSubPushRequestHandler[T]) Handle

func (this PubSubPushRequestHandler[T]) Handle(ginContext *gin.Context)

type Reader

type Reader interface {
	Read(ioReader io.Reader) []byte
}

type RequestHandler

type RequestHandler[T any] interface {
	Handle(ginContext *gin.Context)
}

type RouterBuilder

type RouterBuilder interface {
	Build() *gin.Engine
}