Add generated jet tables and models

These will change with schema changes

.gitignore

@@ -2,15 +2,15 @@
 .sass-cache/
 cmd/geocode-test/geocode-test
 cmd/passwordgen/passwordgen
-db/jet/jet
+/db/jet/jet
 districts/
 flogo.log
 lob/cmd/letter-create/letter-create
 lob/cmd/letter-list/letter-list
 lob/cmd/address-create/address-create
 lob/cmd/address-list/address-list
-nidus-sync
-nidus-sync.log
+/nidus-sync
+/nidus-sync.log
 node_modules/
 postgrid/cmd/send-pdf/send-pdf
 result

db/connection.go

@@ -11,7 +11,7 @@ import (
 	//"github.com/georgysavva/scany/v2/pgxscan"
 	//"github.com/jackc/pgx/v5"
 	"github.com/Gleipnir-Technology/bob"
-	"github.com/go-jet/jet/v2/postgres"
+	"github.com/Gleipnir-Technology/jet/postgres"
 	"github.com/jackc/pgx/v5"
 	"github.com/jackc/pgx/v5/pgxpool"
 	"github.com/jackc/pgx/v5/stdlib"

db/gen/nidus-sync/arcgis/enum/fieldtype.go

@@ -0,0 +1,42 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Fieldtype = &struct {
+	EsriFieldTypeSmallInteger postgres.StringExpression
+	EsriFieldTypeInteger      postgres.StringExpression
+	EsriFieldTypeSingle       postgres.StringExpression
+	EsriFieldTypeDouble       postgres.StringExpression
+	EsriFieldTypeString       postgres.StringExpression
+	EsriFieldTypeDate         postgres.StringExpression
+	EsriFieldTypeOID          postgres.StringExpression
+	EsriFieldTypeGeometry     postgres.StringExpression
+	EsriFieldTypeBlob         postgres.StringExpression
+	EsriFieldTypeRaster       postgres.StringExpression
+	EsriFieldTypeGUID         postgres.StringExpression
+	EsriFieldTypeGlobalID     postgres.StringExpression
+	EsriFieldTypeXML          postgres.StringExpression
+	EsriFieldTypeBigInteger   postgres.StringExpression
+}{
+	EsriFieldTypeSmallInteger: postgres.NewEnumValue("esriFieldTypeSmallInteger"),
+	EsriFieldTypeInteger:      postgres.NewEnumValue("esriFieldTypeInteger"),
+	EsriFieldTypeSingle:       postgres.NewEnumValue("esriFieldTypeSingle"),
+	EsriFieldTypeDouble:       postgres.NewEnumValue("esriFieldTypeDouble"),
+	EsriFieldTypeString:       postgres.NewEnumValue("esriFieldTypeString"),
+	EsriFieldTypeDate:         postgres.NewEnumValue("esriFieldTypeDate"),
+	EsriFieldTypeOID:          postgres.NewEnumValue("esriFieldTypeOID"),
+	EsriFieldTypeGeometry:     postgres.NewEnumValue("esriFieldTypeGeometry"),
+	EsriFieldTypeBlob:         postgres.NewEnumValue("esriFieldTypeBlob"),
+	EsriFieldTypeRaster:       postgres.NewEnumValue("esriFieldTypeRaster"),
+	EsriFieldTypeGUID:         postgres.NewEnumValue("esriFieldTypeGUID"),
+	EsriFieldTypeGlobalID:     postgres.NewEnumValue("esriFieldTypeGlobalID"),
+	EsriFieldTypeXML:          postgres.NewEnumValue("esriFieldTypeXML"),
+	EsriFieldTypeBigInteger:   postgres.NewEnumValue("esriFieldTypeBigInteger"),
+}

db/gen/nidus-sync/arcgis/enum/mappingdestinationaddress.go

@@ -0,0 +1,24 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Mappingdestinationaddress = &struct {
+	Country    postgres.StringExpression
+	Locality   postgres.StringExpression
+	PostalCode postgres.StringExpression
+	Street     postgres.StringExpression
+	Unit       postgres.StringExpression
+}{
+	Country:    postgres.NewEnumValue("country"),
+	Locality:   postgres.NewEnumValue("locality"),
+	PostalCode: postgres.NewEnumValue("postal_code"),
+	Street:     postgres.NewEnumValue("street"),
+	Unit:       postgres.NewEnumValue("unit"),
+}

db/gen/nidus-sync/arcgis/enum/mappingdestinationparcel.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Mappingdestinationparcel = &struct {
+	Apn         postgres.StringExpression
+	Description postgres.StringExpression
+}{
+	Apn:         postgres.NewEnumValue("apn"),
+	Description: postgres.NewEnumValue("description"),
+}

db/gen/nidus-sync/arcgis/model/account.go

@@ -0,0 +1,19 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type Account struct {
+	ID             string `sql:"primary_key"`
+	Name           string
+	OrganizationID int32
+	URLFeatures    *string
+	URLInsights    *string
+	URLGeometry    *string
+	URLNotebooks   *string
+	URLTiles       *string
+}

db/gen/nidus-sync/arcgis/model/address_mapping.go

@@ -0,0 +1,16 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type AddressMapping struct {
+	Destination               Mappingdestinationaddress `sql:"primary_key"`
+	LayerFeatureServiceItemID string
+	LayerIndex                int32
+	LayerFieldName            string
+	OrganizationID            int32 `sql:"primary_key"`
+}

db/gen/nidus-sync/arcgis/model/fieldtype.go

@@ -0,0 +1,97 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Fieldtype string
+
+const (
+	Fieldtype_EsriFieldTypeSmallInteger Fieldtype = "esriFieldTypeSmallInteger"
+	Fieldtype_EsriFieldTypeInteger      Fieldtype = "esriFieldTypeInteger"
+	Fieldtype_EsriFieldTypeSingle       Fieldtype = "esriFieldTypeSingle"
+	Fieldtype_EsriFieldTypeDouble       Fieldtype = "esriFieldTypeDouble"
+	Fieldtype_EsriFieldTypeString       Fieldtype = "esriFieldTypeString"
+	Fieldtype_EsriFieldTypeDate         Fieldtype = "esriFieldTypeDate"
+	Fieldtype_EsriFieldTypeOID          Fieldtype = "esriFieldTypeOID"
+	Fieldtype_EsriFieldTypeGeometry     Fieldtype = "esriFieldTypeGeometry"
+	Fieldtype_EsriFieldTypeBlob         Fieldtype = "esriFieldTypeBlob"
+	Fieldtype_EsriFieldTypeRaster       Fieldtype = "esriFieldTypeRaster"
+	Fieldtype_EsriFieldTypeGUID         Fieldtype = "esriFieldTypeGUID"
+	Fieldtype_EsriFieldTypeGlobalID     Fieldtype = "esriFieldTypeGlobalID"
+	Fieldtype_EsriFieldTypeXML          Fieldtype = "esriFieldTypeXML"
+	Fieldtype_EsriFieldTypeBigInteger   Fieldtype = "esriFieldTypeBigInteger"
+)
+
+var FieldtypeAllValues = []Fieldtype{
+	Fieldtype_EsriFieldTypeSmallInteger,
+	Fieldtype_EsriFieldTypeInteger,
+	Fieldtype_EsriFieldTypeSingle,
+	Fieldtype_EsriFieldTypeDouble,
+	Fieldtype_EsriFieldTypeString,
+	Fieldtype_EsriFieldTypeDate,
+	Fieldtype_EsriFieldTypeOID,
+	Fieldtype_EsriFieldTypeGeometry,
+	Fieldtype_EsriFieldTypeBlob,
+	Fieldtype_EsriFieldTypeRaster,
+	Fieldtype_EsriFieldTypeGUID,
+	Fieldtype_EsriFieldTypeGlobalID,
+	Fieldtype_EsriFieldTypeXML,
+	Fieldtype_EsriFieldTypeBigInteger,
+}
+
+func (e *Fieldtype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "esriFieldTypeSmallInteger":
+		*e = Fieldtype_EsriFieldTypeSmallInteger
+	case "esriFieldTypeInteger":
+		*e = Fieldtype_EsriFieldTypeInteger
+	case "esriFieldTypeSingle":
+		*e = Fieldtype_EsriFieldTypeSingle
+	case "esriFieldTypeDouble":
+		*e = Fieldtype_EsriFieldTypeDouble
+	case "esriFieldTypeString":
+		*e = Fieldtype_EsriFieldTypeString
+	case "esriFieldTypeDate":
+		*e = Fieldtype_EsriFieldTypeDate
+	case "esriFieldTypeOID":
+		*e = Fieldtype_EsriFieldTypeOID
+	case "esriFieldTypeGeometry":
+		*e = Fieldtype_EsriFieldTypeGeometry
+	case "esriFieldTypeBlob":
+		*e = Fieldtype_EsriFieldTypeBlob
+	case "esriFieldTypeRaster":
+		*e = Fieldtype_EsriFieldTypeRaster
+	case "esriFieldTypeGUID":
+		*e = Fieldtype_EsriFieldTypeGUID
+	case "esriFieldTypeGlobalID":
+		*e = Fieldtype_EsriFieldTypeGlobalID
+	case "esriFieldTypeXML":
+		*e = Fieldtype_EsriFieldTypeXML
+	case "esriFieldTypeBigInteger":
+		*e = Fieldtype_EsriFieldTypeBigInteger
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Fieldtype enum")
+	}
+
+	return nil
+}
+
+func (e Fieldtype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/arcgis/model/layer.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+)
+
+type Layer struct {
+	Extent               geom.Bounds
+	FeatureServiceItemID string `sql:"primary_key"`
+	Index                int32  `sql:"primary_key"`
+}

db/gen/nidus-sync/arcgis/model/layer_field.go

@@ -0,0 +1,15 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type LayerField struct {
+	LayerFeatureServiceItemID string `sql:"primary_key"`
+	LayerIndex                int32  `sql:"primary_key"`
+	Name                      string `sql:"primary_key"`
+	Type                      Fieldtype
+}

db/gen/nidus-sync/arcgis/model/mappingdestinationaddress.go

@@ -0,0 +1,61 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Mappingdestinationaddress string
+
+const (
+	Mappingdestinationaddress_Country    Mappingdestinationaddress = "country"
+	Mappingdestinationaddress_Locality   Mappingdestinationaddress = "locality"
+	Mappingdestinationaddress_PostalCode Mappingdestinationaddress = "postal_code"
+	Mappingdestinationaddress_Street     Mappingdestinationaddress = "street"
+	Mappingdestinationaddress_Unit       Mappingdestinationaddress = "unit"
+)
+
+var MappingdestinationaddressAllValues = []Mappingdestinationaddress{
+	Mappingdestinationaddress_Country,
+	Mappingdestinationaddress_Locality,
+	Mappingdestinationaddress_PostalCode,
+	Mappingdestinationaddress_Street,
+	Mappingdestinationaddress_Unit,
+}
+
+func (e *Mappingdestinationaddress) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "country":
+		*e = Mappingdestinationaddress_Country
+	case "locality":
+		*e = Mappingdestinationaddress_Locality
+	case "postal_code":
+		*e = Mappingdestinationaddress_PostalCode
+	case "street":
+		*e = Mappingdestinationaddress_Street
+	case "unit":
+		*e = Mappingdestinationaddress_Unit
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Mappingdestinationaddress enum")
+	}
+
+	return nil
+}
+
+func (e Mappingdestinationaddress) String() string {
+	return string(e)
+}

db/gen/nidus-sync/arcgis/model/mappingdestinationparcel.go

@@ -0,0 +1,49 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Mappingdestinationparcel string
+
+const (
+	Mappingdestinationparcel_Apn         Mappingdestinationparcel = "apn"
+	Mappingdestinationparcel_Description Mappingdestinationparcel = "description"
+)
+
+var MappingdestinationparcelAllValues = []Mappingdestinationparcel{
+	Mappingdestinationparcel_Apn,
+	Mappingdestinationparcel_Description,
+}
+
+func (e *Mappingdestinationparcel) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "apn":
+		*e = Mappingdestinationparcel_Apn
+	case "description":
+		*e = Mappingdestinationparcel_Description
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Mappingdestinationparcel enum")
+	}
+
+	return nil
+}
+
+func (e Mappingdestinationparcel) String() string {
+	return string(e)
+}

db/gen/nidus-sync/arcgis/model/oauth_token.go

@@ -0,0 +1,27 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type OAuthToken struct {
+	AccessToken         string
+	AccessTokenExpires  time.Time
+	ArcgisAccountID     *string
+	ArcgisID            *string
+	ArcgisLicenseTypeID *string
+	Created             time.Time
+	ID                  int32 `sql:"primary_key"`
+	InvalidatedAt       *time.Time
+	RefreshToken        string
+	RefreshTokenExpires time.Time
+	UserID              int32
+	Username            string
+}

db/gen/nidus-sync/arcgis/model/parcel_mapping.go

@@ -0,0 +1,16 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type ParcelMapping struct {
+	Destination               Mappingdestinationparcel `sql:"primary_key"`
+	LayerFeatureServiceItemID string
+	LayerIndex                int32
+	LayerFieldName            string
+	OrganizationID            int32 `sql:"primary_key"`
+}

db/gen/nidus-sync/arcgis/model/service_feature.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+)
+
+type ServiceFeature struct {
+	Extent           geom.Bounds
+	ItemID           string `sql:"primary_key"`
+	SpatialReference int32
+	URL              string
+	AccountID        *string
+}

db/gen/nidus-sync/arcgis/model/service_map.go

@@ -0,0 +1,16 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type ServiceMap struct {
+	AccountID string
+	ArcgisID  string `sql:"primary_key"`
+	Name      string
+	Title     string
+	URL       string
+}

db/gen/nidus-sync/arcgis/model/user_.go

@@ -0,0 +1,29 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type User struct {
+	Access            string
+	Created           time.Time
+	Email             string
+	FullName          string
+	ID                string `sql:"primary_key"`
+	Level             string
+	OrgID             string
+	PublicUserID      int32
+	Region            string
+	Role              string
+	RoleID            string
+	Username          string
+	UserLicenseTypeID string
+	UserType          string
+}

db/gen/nidus-sync/arcgis/model/user_privilege.go

@@ -0,0 +1,13 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type UserPrivilege struct {
+	UserID    string `sql:"primary_key"`
+	Privilege string `sql:"primary_key"`
+}

db/gen/nidus-sync/arcgis/table/account.go

@@ -0,0 +1,99 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var Account = newAccountTable("arcgis", "account", "")
+
+type accountTable struct {
+	postgres.Table
+
+	// Columns
+	ID             postgres.ColumnString
+	Name           postgres.ColumnString
+	OrganizationID postgres.ColumnInteger
+	URLFeatures    postgres.ColumnString
+	URLInsights    postgres.ColumnString
+	URLGeometry    postgres.ColumnString
+	URLNotebooks   postgres.ColumnString
+	URLTiles       postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type AccountTable struct {
+	accountTable
+
+	EXCLUDED accountTable
+}
+
+// AS creates new AccountTable with assigned alias
+func (a AccountTable) AS(alias string) *AccountTable {
+	return newAccountTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new AccountTable with assigned schema name
+func (a AccountTable) FromSchema(schemaName string) *AccountTable {
+	return newAccountTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new AccountTable with assigned table prefix
+func (a AccountTable) WithPrefix(prefix string) *AccountTable {
+	return newAccountTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new AccountTable with assigned table suffix
+func (a AccountTable) WithSuffix(suffix string) *AccountTable {
+	return newAccountTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newAccountTable(schemaName, tableName, alias string) *AccountTable {
+	return &AccountTable{
+		accountTable: newAccountTableImpl(schemaName, tableName, alias),
+		EXCLUDED:     newAccountTableImpl("", "excluded", ""),
+	}
+}
+
+func newAccountTableImpl(schemaName, tableName, alias string) accountTable {
+	var (
+		IDColumn             = postgres.StringColumn("id")
+		NameColumn           = postgres.StringColumn("name")
+		OrganizationIDColumn = postgres.IntegerColumn("organization_id")
+		URLFeaturesColumn    = postgres.StringColumn("url_features")
+		URLInsightsColumn    = postgres.StringColumn("url_insights")
+		URLGeometryColumn    = postgres.StringColumn("url_geometry")
+		URLNotebooksColumn   = postgres.StringColumn("url_notebooks")
+		URLTilesColumn       = postgres.StringColumn("url_tiles")
+		allColumns           = postgres.ColumnList{IDColumn, NameColumn, OrganizationIDColumn, URLFeaturesColumn, URLInsightsColumn, URLGeometryColumn, URLNotebooksColumn, URLTilesColumn}
+		mutableColumns       = postgres.ColumnList{NameColumn, OrganizationIDColumn, URLFeaturesColumn, URLInsightsColumn, URLGeometryColumn, URLNotebooksColumn, URLTilesColumn}
+		defaultColumns       = postgres.ColumnList{}
+	)
+
+	return accountTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		ID:             IDColumn,
+		Name:           NameColumn,
+		OrganizationID: OrganizationIDColumn,
+		URLFeatures:    URLFeaturesColumn,
+		URLInsights:    URLInsightsColumn,
+		URLGeometry:    URLGeometryColumn,
+		URLNotebooks:   URLNotebooksColumn,
+		URLTiles:       URLTilesColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/address_mapping.go

@@ -0,0 +1,90 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var AddressMapping = newAddressMappingTable("arcgis", "address_mapping", "")
+
+type addressMappingTable struct {
+	postgres.Table
+
+	// Columns
+	Destination               postgres.ColumnString
+	LayerFeatureServiceItemID postgres.ColumnString
+	LayerIndex                postgres.ColumnInteger
+	LayerFieldName            postgres.ColumnString
+	OrganizationID            postgres.ColumnInteger
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type AddressMappingTable struct {
+	addressMappingTable
+
+	EXCLUDED addressMappingTable
+}
+
+// AS creates new AddressMappingTable with assigned alias
+func (a AddressMappingTable) AS(alias string) *AddressMappingTable {
+	return newAddressMappingTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new AddressMappingTable with assigned schema name
+func (a AddressMappingTable) FromSchema(schemaName string) *AddressMappingTable {
+	return newAddressMappingTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new AddressMappingTable with assigned table prefix
+func (a AddressMappingTable) WithPrefix(prefix string) *AddressMappingTable {
+	return newAddressMappingTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new AddressMappingTable with assigned table suffix
+func (a AddressMappingTable) WithSuffix(suffix string) *AddressMappingTable {
+	return newAddressMappingTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newAddressMappingTable(schemaName, tableName, alias string) *AddressMappingTable {
+	return &AddressMappingTable{
+		addressMappingTable: newAddressMappingTableImpl(schemaName, tableName, alias),
+		EXCLUDED:            newAddressMappingTableImpl("", "excluded", ""),
+	}
+}
+
+func newAddressMappingTableImpl(schemaName, tableName, alias string) addressMappingTable {
+	var (
+		DestinationColumn               = postgres.StringColumn("destination")
+		LayerFeatureServiceItemIDColumn = postgres.StringColumn("layer_feature_service_item_id")
+		LayerIndexColumn                = postgres.IntegerColumn("layer_index")
+		LayerFieldNameColumn            = postgres.StringColumn("layer_field_name")
+		OrganizationIDColumn            = postgres.IntegerColumn("organization_id")
+		allColumns                      = postgres.ColumnList{DestinationColumn, LayerFeatureServiceItemIDColumn, LayerIndexColumn, LayerFieldNameColumn, OrganizationIDColumn}
+		mutableColumns                  = postgres.ColumnList{LayerFeatureServiceItemIDColumn, LayerIndexColumn, LayerFieldNameColumn}
+		defaultColumns                  = postgres.ColumnList{}
+	)
+
+	return addressMappingTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Destination:               DestinationColumn,
+		LayerFeatureServiceItemID: LayerFeatureServiceItemIDColumn,
+		LayerIndex:                LayerIndexColumn,
+		LayerFieldName:            LayerFieldNameColumn,
+		OrganizationID:            OrganizationIDColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/layer.go

@@ -0,0 +1,84 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var Layer = newLayerTable("arcgis", "layer", "")
+
+type layerTable struct {
+	postgres.Table
+
+	// Columns
+	Extent               postgres.ColumnString
+	FeatureServiceItemID postgres.ColumnString
+	Index                postgres.ColumnInteger
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type LayerTable struct {
+	layerTable
+
+	EXCLUDED layerTable
+}
+
+// AS creates new LayerTable with assigned alias
+func (a LayerTable) AS(alias string) *LayerTable {
+	return newLayerTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new LayerTable with assigned schema name
+func (a LayerTable) FromSchema(schemaName string) *LayerTable {
+	return newLayerTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new LayerTable with assigned table prefix
+func (a LayerTable) WithPrefix(prefix string) *LayerTable {
+	return newLayerTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new LayerTable with assigned table suffix
+func (a LayerTable) WithSuffix(suffix string) *LayerTable {
+	return newLayerTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newLayerTable(schemaName, tableName, alias string) *LayerTable {
+	return &LayerTable{
+		layerTable: newLayerTableImpl(schemaName, tableName, alias),
+		EXCLUDED:   newLayerTableImpl("", "excluded", ""),
+	}
+}
+
+func newLayerTableImpl(schemaName, tableName, alias string) layerTable {
+	var (
+		ExtentColumn               = postgres.StringColumn("extent")
+		FeatureServiceItemIDColumn = postgres.StringColumn("feature_service_item_id")
+		IndexColumn                = postgres.IntegerColumn("index_")
+		allColumns                 = postgres.ColumnList{ExtentColumn, FeatureServiceItemIDColumn, IndexColumn}
+		mutableColumns             = postgres.ColumnList{ExtentColumn}
+		defaultColumns             = postgres.ColumnList{}
+	)
+
+	return layerTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Extent:               ExtentColumn,
+		FeatureServiceItemID: FeatureServiceItemIDColumn,
+		Index:                IndexColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/layer_field.go

@@ -0,0 +1,87 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var LayerField = newLayerFieldTable("arcgis", "layer_field", "")
+
+type layerFieldTable struct {
+	postgres.Table
+
+	// Columns
+	LayerFeatureServiceItemID postgres.ColumnString
+	LayerIndex                postgres.ColumnInteger
+	Name                      postgres.ColumnString
+	Type                      postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type LayerFieldTable struct {
+	layerFieldTable
+
+	EXCLUDED layerFieldTable
+}
+
+// AS creates new LayerFieldTable with assigned alias
+func (a LayerFieldTable) AS(alias string) *LayerFieldTable {
+	return newLayerFieldTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new LayerFieldTable with assigned schema name
+func (a LayerFieldTable) FromSchema(schemaName string) *LayerFieldTable {
+	return newLayerFieldTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new LayerFieldTable with assigned table prefix
+func (a LayerFieldTable) WithPrefix(prefix string) *LayerFieldTable {
+	return newLayerFieldTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new LayerFieldTable with assigned table suffix
+func (a LayerFieldTable) WithSuffix(suffix string) *LayerFieldTable {
+	return newLayerFieldTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newLayerFieldTable(schemaName, tableName, alias string) *LayerFieldTable {
+	return &LayerFieldTable{
+		layerFieldTable: newLayerFieldTableImpl(schemaName, tableName, alias),
+		EXCLUDED:        newLayerFieldTableImpl("", "excluded", ""),
+	}
+}
+
+func newLayerFieldTableImpl(schemaName, tableName, alias string) layerFieldTable {
+	var (
+		LayerFeatureServiceItemIDColumn = postgres.StringColumn("layer_feature_service_item_id")
+		LayerIndexColumn                = postgres.IntegerColumn("layer_index")
+		NameColumn                      = postgres.StringColumn("name")
+		TypeColumn                      = postgres.StringColumn("type_")
+		allColumns                      = postgres.ColumnList{LayerFeatureServiceItemIDColumn, LayerIndexColumn, NameColumn, TypeColumn}
+		mutableColumns                  = postgres.ColumnList{TypeColumn}
+		defaultColumns                  = postgres.ColumnList{}
+	)
+
+	return layerFieldTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		LayerFeatureServiceItemID: LayerFeatureServiceItemIDColumn,
+		LayerIndex:                LayerIndexColumn,
+		Name:                      NameColumn,
+		Type:                      TypeColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/oauth_token.go

@@ -0,0 +1,111 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var OAuthToken = newOAuthTokenTable("arcgis", "oauth_token", "")
+
+type oAuthTokenTable struct {
+	postgres.Table
+
+	// Columns
+	AccessToken         postgres.ColumnString
+	AccessTokenExpires  postgres.ColumnTimestamp
+	ArcgisAccountID     postgres.ColumnString
+	ArcgisID            postgres.ColumnString
+	ArcgisLicenseTypeID postgres.ColumnString
+	Created             postgres.ColumnTimestamp
+	ID                  postgres.ColumnInteger
+	InvalidatedAt       postgres.ColumnTimestamp
+	RefreshToken        postgres.ColumnString
+	RefreshTokenExpires postgres.ColumnTimestamp
+	UserID              postgres.ColumnInteger
+	Username            postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type OAuthTokenTable struct {
+	oAuthTokenTable
+
+	EXCLUDED oAuthTokenTable
+}
+
+// AS creates new OAuthTokenTable with assigned alias
+func (a OAuthTokenTable) AS(alias string) *OAuthTokenTable {
+	return newOAuthTokenTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new OAuthTokenTable with assigned schema name
+func (a OAuthTokenTable) FromSchema(schemaName string) *OAuthTokenTable {
+	return newOAuthTokenTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new OAuthTokenTable with assigned table prefix
+func (a OAuthTokenTable) WithPrefix(prefix string) *OAuthTokenTable {
+	return newOAuthTokenTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new OAuthTokenTable with assigned table suffix
+func (a OAuthTokenTable) WithSuffix(suffix string) *OAuthTokenTable {
+	return newOAuthTokenTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newOAuthTokenTable(schemaName, tableName, alias string) *OAuthTokenTable {
+	return &OAuthTokenTable{
+		oAuthTokenTable: newOAuthTokenTableImpl(schemaName, tableName, alias),
+		EXCLUDED:        newOAuthTokenTableImpl("", "excluded", ""),
+	}
+}
+
+func newOAuthTokenTableImpl(schemaName, tableName, alias string) oAuthTokenTable {
+	var (
+		AccessTokenColumn         = postgres.StringColumn("access_token")
+		AccessTokenExpiresColumn  = postgres.TimestampColumn("access_token_expires")
+		ArcgisAccountIDColumn     = postgres.StringColumn("arcgis_account_id")
+		ArcgisIDColumn            = postgres.StringColumn("arcgis_id")
+		ArcgisLicenseTypeIDColumn = postgres.StringColumn("arcgis_license_type_id")
+		CreatedColumn             = postgres.TimestampColumn("created")
+		IDColumn                  = postgres.IntegerColumn("id")
+		InvalidatedAtColumn       = postgres.TimestampColumn("invalidated_at")
+		RefreshTokenColumn        = postgres.StringColumn("refresh_token")
+		RefreshTokenExpiresColumn = postgres.TimestampColumn("refresh_token_expires")
+		UserIDColumn              = postgres.IntegerColumn("user_id")
+		UsernameColumn            = postgres.StringColumn("username")
+		allColumns                = postgres.ColumnList{AccessTokenColumn, AccessTokenExpiresColumn, ArcgisAccountIDColumn, ArcgisIDColumn, ArcgisLicenseTypeIDColumn, CreatedColumn, IDColumn, InvalidatedAtColumn, RefreshTokenColumn, RefreshTokenExpiresColumn, UserIDColumn, UsernameColumn}
+		mutableColumns            = postgres.ColumnList{AccessTokenColumn, AccessTokenExpiresColumn, ArcgisAccountIDColumn, ArcgisIDColumn, ArcgisLicenseTypeIDColumn, CreatedColumn, InvalidatedAtColumn, RefreshTokenColumn, RefreshTokenExpiresColumn, UserIDColumn, UsernameColumn}
+		defaultColumns            = postgres.ColumnList{IDColumn}
+	)
+
+	return oAuthTokenTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		AccessToken:         AccessTokenColumn,
+		AccessTokenExpires:  AccessTokenExpiresColumn,
+		ArcgisAccountID:     ArcgisAccountIDColumn,
+		ArcgisID:            ArcgisIDColumn,
+		ArcgisLicenseTypeID: ArcgisLicenseTypeIDColumn,
+		Created:             CreatedColumn,
+		ID:                  IDColumn,
+		InvalidatedAt:       InvalidatedAtColumn,
+		RefreshToken:        RefreshTokenColumn,
+		RefreshTokenExpires: RefreshTokenExpiresColumn,
+		UserID:              UserIDColumn,
+		Username:            UsernameColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/parcel_mapping.go

@@ -0,0 +1,90 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var ParcelMapping = newParcelMappingTable("arcgis", "parcel_mapping", "")
+
+type parcelMappingTable struct {
+	postgres.Table
+
+	// Columns
+	Destination               postgres.ColumnString
+	LayerFeatureServiceItemID postgres.ColumnString
+	LayerIndex                postgres.ColumnInteger
+	LayerFieldName            postgres.ColumnString
+	OrganizationID            postgres.ColumnInteger
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type ParcelMappingTable struct {
+	parcelMappingTable
+
+	EXCLUDED parcelMappingTable
+}
+
+// AS creates new ParcelMappingTable with assigned alias
+func (a ParcelMappingTable) AS(alias string) *ParcelMappingTable {
+	return newParcelMappingTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new ParcelMappingTable with assigned schema name
+func (a ParcelMappingTable) FromSchema(schemaName string) *ParcelMappingTable {
+	return newParcelMappingTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new ParcelMappingTable with assigned table prefix
+func (a ParcelMappingTable) WithPrefix(prefix string) *ParcelMappingTable {
+	return newParcelMappingTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new ParcelMappingTable with assigned table suffix
+func (a ParcelMappingTable) WithSuffix(suffix string) *ParcelMappingTable {
+	return newParcelMappingTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newParcelMappingTable(schemaName, tableName, alias string) *ParcelMappingTable {
+	return &ParcelMappingTable{
+		parcelMappingTable: newParcelMappingTableImpl(schemaName, tableName, alias),
+		EXCLUDED:           newParcelMappingTableImpl("", "excluded", ""),
+	}
+}
+
+func newParcelMappingTableImpl(schemaName, tableName, alias string) parcelMappingTable {
+	var (
+		DestinationColumn               = postgres.StringColumn("destination")
+		LayerFeatureServiceItemIDColumn = postgres.StringColumn("layer_feature_service_item_id")
+		LayerIndexColumn                = postgres.IntegerColumn("layer_index")
+		LayerFieldNameColumn            = postgres.StringColumn("layer_field_name")
+		OrganizationIDColumn            = postgres.IntegerColumn("organization_id")
+		allColumns                      = postgres.ColumnList{DestinationColumn, LayerFeatureServiceItemIDColumn, LayerIndexColumn, LayerFieldNameColumn, OrganizationIDColumn}
+		mutableColumns                  = postgres.ColumnList{LayerFeatureServiceItemIDColumn, LayerIndexColumn, LayerFieldNameColumn}
+		defaultColumns                  = postgres.ColumnList{}
+	)
+
+	return parcelMappingTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Destination:               DestinationColumn,
+		LayerFeatureServiceItemID: LayerFeatureServiceItemIDColumn,
+		LayerIndex:                LayerIndexColumn,
+		LayerFieldName:            LayerFieldNameColumn,
+		OrganizationID:            OrganizationIDColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/service_feature.go

@@ -0,0 +1,90 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var ServiceFeature = newServiceFeatureTable("arcgis", "service_feature", "")
+
+type serviceFeatureTable struct {
+	postgres.Table
+
+	// Columns
+	Extent           postgres.ColumnString
+	ItemID           postgres.ColumnString
+	SpatialReference postgres.ColumnInteger
+	URL              postgres.ColumnString
+	AccountID        postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type ServiceFeatureTable struct {
+	serviceFeatureTable
+
+	EXCLUDED serviceFeatureTable
+}
+
+// AS creates new ServiceFeatureTable with assigned alias
+func (a ServiceFeatureTable) AS(alias string) *ServiceFeatureTable {
+	return newServiceFeatureTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new ServiceFeatureTable with assigned schema name
+func (a ServiceFeatureTable) FromSchema(schemaName string) *ServiceFeatureTable {
+	return newServiceFeatureTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new ServiceFeatureTable with assigned table prefix
+func (a ServiceFeatureTable) WithPrefix(prefix string) *ServiceFeatureTable {
+	return newServiceFeatureTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new ServiceFeatureTable with assigned table suffix
+func (a ServiceFeatureTable) WithSuffix(suffix string) *ServiceFeatureTable {
+	return newServiceFeatureTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newServiceFeatureTable(schemaName, tableName, alias string) *ServiceFeatureTable {
+	return &ServiceFeatureTable{
+		serviceFeatureTable: newServiceFeatureTableImpl(schemaName, tableName, alias),
+		EXCLUDED:            newServiceFeatureTableImpl("", "excluded", ""),
+	}
+}
+
+func newServiceFeatureTableImpl(schemaName, tableName, alias string) serviceFeatureTable {
+	var (
+		ExtentColumn           = postgres.StringColumn("extent")
+		ItemIDColumn           = postgres.StringColumn("item_id")
+		SpatialReferenceColumn = postgres.IntegerColumn("spatial_reference")
+		URLColumn              = postgres.StringColumn("url")
+		AccountIDColumn        = postgres.StringColumn("account_id")
+		allColumns             = postgres.ColumnList{ExtentColumn, ItemIDColumn, SpatialReferenceColumn, URLColumn, AccountIDColumn}
+		mutableColumns         = postgres.ColumnList{ExtentColumn, SpatialReferenceColumn, URLColumn, AccountIDColumn}
+		defaultColumns         = postgres.ColumnList{}
+	)
+
+	return serviceFeatureTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Extent:           ExtentColumn,
+		ItemID:           ItemIDColumn,
+		SpatialReference: SpatialReferenceColumn,
+		URL:              URLColumn,
+		AccountID:        AccountIDColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/service_map.go

@@ -0,0 +1,90 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var ServiceMap = newServiceMapTable("arcgis", "service_map", "")
+
+type serviceMapTable struct {
+	postgres.Table
+
+	// Columns
+	AccountID postgres.ColumnString
+	ArcgisID  postgres.ColumnString
+	Name      postgres.ColumnString
+	Title     postgres.ColumnString
+	URL       postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type ServiceMapTable struct {
+	serviceMapTable
+
+	EXCLUDED serviceMapTable
+}
+
+// AS creates new ServiceMapTable with assigned alias
+func (a ServiceMapTable) AS(alias string) *ServiceMapTable {
+	return newServiceMapTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new ServiceMapTable with assigned schema name
+func (a ServiceMapTable) FromSchema(schemaName string) *ServiceMapTable {
+	return newServiceMapTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new ServiceMapTable with assigned table prefix
+func (a ServiceMapTable) WithPrefix(prefix string) *ServiceMapTable {
+	return newServiceMapTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new ServiceMapTable with assigned table suffix
+func (a ServiceMapTable) WithSuffix(suffix string) *ServiceMapTable {
+	return newServiceMapTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newServiceMapTable(schemaName, tableName, alias string) *ServiceMapTable {
+	return &ServiceMapTable{
+		serviceMapTable: newServiceMapTableImpl(schemaName, tableName, alias),
+		EXCLUDED:        newServiceMapTableImpl("", "excluded", ""),
+	}
+}
+
+func newServiceMapTableImpl(schemaName, tableName, alias string) serviceMapTable {
+	var (
+		AccountIDColumn = postgres.StringColumn("account_id")
+		ArcgisIDColumn  = postgres.StringColumn("arcgis_id")
+		NameColumn      = postgres.StringColumn("name")
+		TitleColumn     = postgres.StringColumn("title")
+		URLColumn       = postgres.StringColumn("url")
+		allColumns      = postgres.ColumnList{AccountIDColumn, ArcgisIDColumn, NameColumn, TitleColumn, URLColumn}
+		mutableColumns  = postgres.ColumnList{AccountIDColumn, NameColumn, TitleColumn, URLColumn}
+		defaultColumns  = postgres.ColumnList{}
+	)
+
+	return serviceMapTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		AccountID: AccountIDColumn,
+		ArcgisID:  ArcgisIDColumn,
+		Name:      NameColumn,
+		Title:     TitleColumn,
+		URL:       URLColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/table_use_schema.go

@@ -0,0 +1,23 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+// UseSchema sets a new schema name for all generated table SQL builder types. It is recommended to invoke
+// this method only once at the beginning of the program.
+func UseSchema(schema string) {
+	Account = Account.FromSchema(schema)
+	AddressMapping = AddressMapping.FromSchema(schema)
+	Layer = Layer.FromSchema(schema)
+	LayerField = LayerField.FromSchema(schema)
+	OAuthToken = OAuthToken.FromSchema(schema)
+	ParcelMapping = ParcelMapping.FromSchema(schema)
+	ServiceFeature = ServiceFeature.FromSchema(schema)
+	ServiceMap = ServiceMap.FromSchema(schema)
+	User = User.FromSchema(schema)
+	UserPrivilege = UserPrivilege.FromSchema(schema)
+}

db/gen/nidus-sync/arcgis/table/user_.go

@@ -0,0 +1,117 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var User = newUserTable("arcgis", "user_", "")
+
+type userTable struct {
+	postgres.Table
+
+	// Columns
+	Access            postgres.ColumnString
+	Created           postgres.ColumnTimestamp
+	Email             postgres.ColumnString
+	FullName          postgres.ColumnString
+	ID                postgres.ColumnString
+	Level             postgres.ColumnString
+	OrgID             postgres.ColumnString
+	PublicUserID      postgres.ColumnInteger
+	Region            postgres.ColumnString
+	Role              postgres.ColumnString
+	RoleID            postgres.ColumnString
+	Username          postgres.ColumnString
+	UserLicenseTypeID postgres.ColumnString
+	UserType          postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type UserTable struct {
+	userTable
+
+	EXCLUDED userTable
+}
+
+// AS creates new UserTable with assigned alias
+func (a UserTable) AS(alias string) *UserTable {
+	return newUserTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new UserTable with assigned schema name
+func (a UserTable) FromSchema(schemaName string) *UserTable {
+	return newUserTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new UserTable with assigned table prefix
+func (a UserTable) WithPrefix(prefix string) *UserTable {
+	return newUserTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new UserTable with assigned table suffix
+func (a UserTable) WithSuffix(suffix string) *UserTable {
+	return newUserTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newUserTable(schemaName, tableName, alias string) *UserTable {
+	return &UserTable{
+		userTable: newUserTableImpl(schemaName, tableName, alias),
+		EXCLUDED:  newUserTableImpl("", "excluded", ""),
+	}
+}
+
+func newUserTableImpl(schemaName, tableName, alias string) userTable {
+	var (
+		AccessColumn            = postgres.StringColumn("access")
+		CreatedColumn           = postgres.TimestampColumn("created")
+		EmailColumn             = postgres.StringColumn("email")
+		FullNameColumn          = postgres.StringColumn("full_name")
+		IDColumn                = postgres.StringColumn("id")
+		LevelColumn             = postgres.StringColumn("level")
+		OrgIDColumn             = postgres.StringColumn("org_id")
+		PublicUserIDColumn      = postgres.IntegerColumn("public_user_id")
+		RegionColumn            = postgres.StringColumn("region")
+		RoleColumn              = postgres.StringColumn("role")
+		RoleIDColumn            = postgres.StringColumn("role_id")
+		UsernameColumn          = postgres.StringColumn("username")
+		UserLicenseTypeIDColumn = postgres.StringColumn("user_license_type_id")
+		UserTypeColumn          = postgres.StringColumn("user_type")
+		allColumns              = postgres.ColumnList{AccessColumn, CreatedColumn, EmailColumn, FullNameColumn, IDColumn, LevelColumn, OrgIDColumn, PublicUserIDColumn, RegionColumn, RoleColumn, RoleIDColumn, UsernameColumn, UserLicenseTypeIDColumn, UserTypeColumn}
+		mutableColumns          = postgres.ColumnList{AccessColumn, CreatedColumn, EmailColumn, FullNameColumn, LevelColumn, OrgIDColumn, PublicUserIDColumn, RegionColumn, RoleColumn, RoleIDColumn, UsernameColumn, UserLicenseTypeIDColumn, UserTypeColumn}
+		defaultColumns          = postgres.ColumnList{}
+	)
+
+	return userTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Access:            AccessColumn,
+		Created:           CreatedColumn,
+		Email:             EmailColumn,
+		FullName:          FullNameColumn,
+		ID:                IDColumn,
+		Level:             LevelColumn,
+		OrgID:             OrgIDColumn,
+		PublicUserID:      PublicUserIDColumn,
+		Region:            RegionColumn,
+		Role:              RoleColumn,
+		RoleID:            RoleIDColumn,
+		Username:          UsernameColumn,
+		UserLicenseTypeID: UserLicenseTypeIDColumn,
+		UserType:          UserTypeColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/arcgis/table/user_privilege.go

@@ -0,0 +1,81 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var UserPrivilege = newUserPrivilegeTable("arcgis", "user_privilege", "")
+
+type userPrivilegeTable struct {
+	postgres.Table
+
+	// Columns
+	UserID    postgres.ColumnString
+	Privilege postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type UserPrivilegeTable struct {
+	userPrivilegeTable
+
+	EXCLUDED userPrivilegeTable
+}
+
+// AS creates new UserPrivilegeTable with assigned alias
+func (a UserPrivilegeTable) AS(alias string) *UserPrivilegeTable {
+	return newUserPrivilegeTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new UserPrivilegeTable with assigned schema name
+func (a UserPrivilegeTable) FromSchema(schemaName string) *UserPrivilegeTable {
+	return newUserPrivilegeTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new UserPrivilegeTable with assigned table prefix
+func (a UserPrivilegeTable) WithPrefix(prefix string) *UserPrivilegeTable {
+	return newUserPrivilegeTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new UserPrivilegeTable with assigned table suffix
+func (a UserPrivilegeTable) WithSuffix(suffix string) *UserPrivilegeTable {
+	return newUserPrivilegeTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newUserPrivilegeTable(schemaName, tableName, alias string) *UserPrivilegeTable {
+	return &UserPrivilegeTable{
+		userPrivilegeTable: newUserPrivilegeTableImpl(schemaName, tableName, alias),
+		EXCLUDED:           newUserPrivilegeTableImpl("", "excluded", ""),
+	}
+}
+
+func newUserPrivilegeTableImpl(schemaName, tableName, alias string) userPrivilegeTable {
+	var (
+		UserIDColumn    = postgres.StringColumn("user_id")
+		PrivilegeColumn = postgres.StringColumn("privilege")
+		allColumns      = postgres.ColumnList{UserIDColumn, PrivilegeColumn}
+		mutableColumns  = postgres.ColumnList{}
+		defaultColumns  = postgres.ColumnList{}
+	)
+
+	return userPrivilegeTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		UserID:    UserIDColumn,
+		Privilege: PrivilegeColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/public/enum/arcgislicensetype.go

@@ -0,0 +1,42 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Arcgislicensetype = &struct {
+	AdvancedUT             postgres.StringExpression
+	BasicUT                postgres.StringExpression
+	CreatorUT              postgres.StringExpression
+	EditorUT               postgres.StringExpression
+	FieldWorkerUT          postgres.StringExpression
+	GisprofessionalAdvUT   postgres.StringExpression
+	GisprofessionalBasicUT postgres.StringExpression
+	GisprofessionalStdUT   postgres.StringExpression
+	IndoorsUserUT          postgres.StringExpression
+	InsightsAnalystUT      postgres.StringExpression
+	LiteUT                 postgres.StringExpression
+	StandardUT             postgres.StringExpression
+	StorytellerUT          postgres.StringExpression
+	ViewerUT               postgres.StringExpression
+}{
+	AdvancedUT:             postgres.NewEnumValue("advancedUT"),
+	BasicUT:                postgres.NewEnumValue("basicUT"),
+	CreatorUT:              postgres.NewEnumValue("creatorUT"),
+	EditorUT:               postgres.NewEnumValue("editorUT"),
+	FieldWorkerUT:          postgres.NewEnumValue("fieldWorkerUT"),
+	GisprofessionalAdvUT:   postgres.NewEnumValue("GISProfessionalAdvUT"),
+	GisprofessionalBasicUT: postgres.NewEnumValue("GISProfessionalBasicUT"),
+	GisprofessionalStdUT:   postgres.NewEnumValue("GISProfessionalStdUT"),
+	IndoorsUserUT:          postgres.NewEnumValue("IndoorsUserUT"),
+	InsightsAnalystUT:      postgres.NewEnumValue("insightsAnalystUT"),
+	LiteUT:                 postgres.NewEnumValue("liteUT"),
+	StandardUT:             postgres.NewEnumValue("standardUT"),
+	StorytellerUT:          postgres.NewEnumValue("storytellerUT"),
+	ViewerUT:               postgres.NewEnumValue("viewerUT"),
+}

db/gen/nidus-sync/public/enum/audiodatatype.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Audiodatatype = &struct {
+	Raw           postgres.StringExpression
+	RawNormalized postgres.StringExpression
+	Ogg           postgres.StringExpression
+}{
+	Raw:           postgres.NewEnumValue("raw"),
+	RawNormalized: postgres.NewEnumValue("raw_normalized"),
+	Ogg:           postgres.NewEnumValue("ogg"),
+}

db/gen/nidus-sync/public/enum/communicationlogentry.go

@@ -0,0 +1,28 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Communicationlogentry = &struct {
+	Created                postgres.StringExpression
+	StatusClosed           postgres.StringExpression
+	StatusInvalidated      postgres.StringExpression
+	StatusOpened           postgres.StringExpression
+	StatusPending          postgres.StringExpression
+	StatusPossibleIssue    postgres.StringExpression
+	StatusPossibleResolved postgres.StringExpression
+}{
+	Created:                postgres.NewEnumValue("created"),
+	StatusClosed:           postgres.NewEnumValue("status.closed"),
+	StatusInvalidated:      postgres.NewEnumValue("status.invalidated"),
+	StatusOpened:           postgres.NewEnumValue("status.opened"),
+	StatusPending:          postgres.NewEnumValue("status.pending"),
+	StatusPossibleIssue:    postgres.NewEnumValue("status.possible-issue"),
+	StatusPossibleResolved: postgres.NewEnumValue("status.possible-resolved"),
+}

db/gen/nidus-sync/public/enum/communicationstatus.go

@@ -0,0 +1,30 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Communicationstatus = &struct {
+	Closed           postgres.StringExpression
+	Invalid          postgres.StringExpression
+	New              postgres.StringExpression
+	Opened           postgres.StringExpression
+	Pending          postgres.StringExpression
+	PossibleIssue    postgres.StringExpression
+	PossibleResolved postgres.StringExpression
+	Resolved         postgres.StringExpression
+}{
+	Closed:           postgres.NewEnumValue("closed"),
+	Invalid:          postgres.NewEnumValue("invalid"),
+	New:              postgres.NewEnumValue("new"),
+	Opened:           postgres.NewEnumValue("opened"),
+	Pending:          postgres.NewEnumValue("pending"),
+	PossibleIssue:    postgres.NewEnumValue("possible-issue"),
+	PossibleResolved: postgres.NewEnumValue("possible-resolved"),
+	Resolved:         postgres.NewEnumValue("resolved"),
+}

db/gen/nidus-sync/public/enum/communicationstatustype.go

@@ -0,0 +1,30 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Communicationstatustype = &struct {
+	Closed           postgres.StringExpression
+	Invalid          postgres.StringExpression
+	New              postgres.StringExpression
+	Opened           postgres.StringExpression
+	Pending          postgres.StringExpression
+	PossibleIssue    postgres.StringExpression
+	PossibleResolved postgres.StringExpression
+	Resolved         postgres.StringExpression
+}{
+	Closed:           postgres.NewEnumValue("closed"),
+	Invalid:          postgres.NewEnumValue("invalid"),
+	New:              postgres.NewEnumValue("new"),
+	Opened:           postgres.NewEnumValue("opened"),
+	Pending:          postgres.NewEnumValue("pending"),
+	PossibleIssue:    postgres.NewEnumValue("possible-issue"),
+	PossibleResolved: postgres.NewEnumValue("possible-resolved"),
+	Resolved:         postgres.NewEnumValue("resolved"),
+}

db/gen/nidus-sync/public/enum/h3aggregationtype.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var H3aggregationtype = &struct {
+	MosquitoSource postgres.StringExpression
+	ServiceRequest postgres.StringExpression
+	Trap           postgres.StringExpression
+}{
+	MosquitoSource: postgres.NewEnumValue("MosquitoSource"),
+	ServiceRequest: postgres.NewEnumValue("ServiceRequest"),
+	Trap:           postgres.NewEnumValue("Trap"),
+}

db/gen/nidus-sync/public/enum/hashtype.go

@@ -0,0 +1,16 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Hashtype = &struct {
+	Bcrypt14 postgres.StringExpression
+}{
+	Bcrypt14: postgres.NewEnumValue("bcrypt-14"),
+}

db/gen/nidus-sync/public/enum/imagedatatype.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Imagedatatype = &struct {
+	Raw postgres.StringExpression
+	Png postgres.StringExpression
+}{
+	Raw: postgres.NewEnumValue("raw"),
+	Png: postgres.NewEnumValue("png"),
+}

db/gen/nidus-sync/public/enum/jobtype.go

@@ -0,0 +1,30 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Jobtype = &struct {
+	AudioTranscode         postgres.StringExpression
+	CsvCommit              postgres.StringExpression
+	CsvImport              postgres.StringExpression
+	LabelStudioAudioCreate postgres.StringExpression
+	EmailSend              postgres.StringExpression
+	TextRespond            postgres.StringExpression
+	TextSend               postgres.StringExpression
+	ComplianceMailerSend   postgres.StringExpression
+}{
+	AudioTranscode:         postgres.NewEnumValue("audio-transcode"),
+	CsvCommit:              postgres.NewEnumValue("csv-commit"),
+	CsvImport:              postgres.NewEnumValue("csv-import"),
+	LabelStudioAudioCreate: postgres.NewEnumValue("label-studio-audio-create"),
+	EmailSend:              postgres.NewEnumValue("email-send"),
+	TextRespond:            postgres.NewEnumValue("text-respond"),
+	TextSend:               postgres.NewEnumValue("text-send"),
+	ComplianceMailerSend:   postgres.NewEnumValue("compliance-mailer-send"),
+}

db/gen/nidus-sync/public/enum/leadtype.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Leadtype = &struct {
+	Unknown              postgres.StringExpression
+	GreenPool            postgres.StringExpression
+	PublicreportNuisance postgres.StringExpression
+	PublicreportWater    postgres.StringExpression
+}{
+	Unknown:              postgres.NewEnumValue("unknown"),
+	GreenPool:            postgres.NewEnumValue("green-pool"),
+	PublicreportNuisance: postgres.NewEnumValue("publicreport-nuisance"),
+	PublicreportWater:    postgres.NewEnumValue("publicreport-water"),
+}

db/gen/nidus-sync/public/enum/mosquitospecies.go

@@ -0,0 +1,24 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Mosquitospecies = &struct {
+	None            postgres.StringExpression
+	AedesAegypti    postgres.StringExpression
+	AedesAlbopictus postgres.StringExpression
+	CulexPipiens    postgres.StringExpression
+	CulexTarsalis   postgres.StringExpression
+}{
+	None:            postgres.NewEnumValue("none"),
+	AedesAegypti:    postgres.NewEnumValue("aedes aegypti"),
+	AedesAlbopictus: postgres.NewEnumValue("aedes albopictus"),
+	CulexPipiens:    postgres.NewEnumValue("culex pipiens"),
+	CulexTarsalis:   postgres.NewEnumValue("culex tarsalis"),
+}

db/gen/nidus-sync/public/enum/notificationtype.go

@@ -0,0 +1,16 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Notificationtype = &struct {
+	OAuthTokenInvalidated postgres.StringExpression
+}{
+	OAuthTokenInvalidated: postgres.NewEnumValue("oauth_token_invalidated"),
+}

db/gen/nidus-sync/public/enum/poolconditiontype.go

@@ -0,0 +1,26 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Poolconditiontype = &struct {
+	Blue      postgres.StringExpression
+	Dry       postgres.StringExpression
+	FalsePool postgres.StringExpression
+	Unknown   postgres.StringExpression
+	Green     postgres.StringExpression
+	Murky     postgres.StringExpression
+}{
+	Blue:      postgres.NewEnumValue("blue"),
+	Dry:       postgres.NewEnumValue("dry"),
+	FalsePool: postgres.NewEnumValue("false pool"),
+	Unknown:   postgres.NewEnumValue("unknown"),
+	Green:     postgres.NewEnumValue("green"),
+	Murky:     postgres.NewEnumValue("murky"),
+}

db/gen/nidus-sync/public/enum/reviewtaskresolutiontype.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Reviewtaskresolutiontype = &struct {
+	Committed postgres.StringExpression
+	Discarded postgres.StringExpression
+}{
+	Committed: postgres.NewEnumValue("committed"),
+	Discarded: postgres.NewEnumValue("discarded"),
+}

db/gen/nidus-sync/public/enum/signaltype.go

@@ -0,0 +1,28 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Signaltype = &struct {
+	FlyoverPool             postgres.StringExpression
+	PlanFollowup            postgres.StringExpression
+	PublicreportWater       postgres.StringExpression
+	PublicreportNuisance    postgres.StringExpression
+	ResidualExiring         postgres.StringExpression
+	SurveillanceObservation postgres.StringExpression
+	TrapSpike               postgres.StringExpression
+}{
+	FlyoverPool:             postgres.NewEnumValue("flyover pool"),
+	PlanFollowup:            postgres.NewEnumValue("plan followup"),
+	PublicreportWater:       postgres.NewEnumValue("publicreport water"),
+	PublicreportNuisance:    postgres.NewEnumValue("publicreport nuisance"),
+	ResidualExiring:         postgres.NewEnumValue("residual exiring"),
+	SurveillanceObservation: postgres.NewEnumValue("surveillance observation"),
+	TrapSpike:               postgres.NewEnumValue("trap spike"),
+}

db/gen/nidus-sync/public/enum/userrole.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package enum
+
+import "github.com/Gleipnir-Technology/jet/postgres"
+
+var Userrole = &struct {
+	Root         postgres.StringExpression
+	AccountOwner postgres.StringExpression
+}{
+	Root:         postgres.NewEnumValue("root"),
+	AccountOwner: postgres.NewEnumValue("account-owner"),
+}

db/gen/nidus-sync/public/model/address.go

@@ -0,0 +1,28 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+	"time"
+)
+
+type Address struct {
+	Country    string
+	Created    time.Time
+	Location   geom.T
+	H3cell     string
+	ID         int32 `sql:"primary_key"`
+	Locality   string
+	PostalCode string
+	Street     string
+	Unit       string
+	Region     string
+	Number     string
+	Gid        string
+}

db/gen/nidus-sync/public/model/arcgislicensetype.go

@@ -0,0 +1,97 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Arcgislicensetype string
+
+const (
+	Arcgislicensetype_AdvancedUT             Arcgislicensetype = "advancedUT"
+	Arcgislicensetype_BasicUT                Arcgislicensetype = "basicUT"
+	Arcgislicensetype_CreatorUT              Arcgislicensetype = "creatorUT"
+	Arcgislicensetype_EditorUT               Arcgislicensetype = "editorUT"
+	Arcgislicensetype_FieldWorkerUT          Arcgislicensetype = "fieldWorkerUT"
+	Arcgislicensetype_GisprofessionalAdvUT   Arcgislicensetype = "GISProfessionalAdvUT"
+	Arcgislicensetype_GisprofessionalBasicUT Arcgislicensetype = "GISProfessionalBasicUT"
+	Arcgislicensetype_GisprofessionalStdUT   Arcgislicensetype = "GISProfessionalStdUT"
+	Arcgislicensetype_IndoorsUserUT          Arcgislicensetype = "IndoorsUserUT"
+	Arcgislicensetype_InsightsAnalystUT      Arcgislicensetype = "insightsAnalystUT"
+	Arcgislicensetype_LiteUT                 Arcgislicensetype = "liteUT"
+	Arcgislicensetype_StandardUT             Arcgislicensetype = "standardUT"
+	Arcgislicensetype_StorytellerUT          Arcgislicensetype = "storytellerUT"
+	Arcgislicensetype_ViewerUT               Arcgislicensetype = "viewerUT"
+)
+
+var ArcgislicensetypeAllValues = []Arcgislicensetype{
+	Arcgislicensetype_AdvancedUT,
+	Arcgislicensetype_BasicUT,
+	Arcgislicensetype_CreatorUT,
+	Arcgislicensetype_EditorUT,
+	Arcgislicensetype_FieldWorkerUT,
+	Arcgislicensetype_GisprofessionalAdvUT,
+	Arcgislicensetype_GisprofessionalBasicUT,
+	Arcgislicensetype_GisprofessionalStdUT,
+	Arcgislicensetype_IndoorsUserUT,
+	Arcgislicensetype_InsightsAnalystUT,
+	Arcgislicensetype_LiteUT,
+	Arcgislicensetype_StandardUT,
+	Arcgislicensetype_StorytellerUT,
+	Arcgislicensetype_ViewerUT,
+}
+
+func (e *Arcgislicensetype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "advancedUT":
+		*e = Arcgislicensetype_AdvancedUT
+	case "basicUT":
+		*e = Arcgislicensetype_BasicUT
+	case "creatorUT":
+		*e = Arcgislicensetype_CreatorUT
+	case "editorUT":
+		*e = Arcgislicensetype_EditorUT
+	case "fieldWorkerUT":
+		*e = Arcgislicensetype_FieldWorkerUT
+	case "GISProfessionalAdvUT":
+		*e = Arcgislicensetype_GisprofessionalAdvUT
+	case "GISProfessionalBasicUT":
+		*e = Arcgislicensetype_GisprofessionalBasicUT
+	case "GISProfessionalStdUT":
+		*e = Arcgislicensetype_GisprofessionalStdUT
+	case "IndoorsUserUT":
+		*e = Arcgislicensetype_IndoorsUserUT
+	case "insightsAnalystUT":
+		*e = Arcgislicensetype_InsightsAnalystUT
+	case "liteUT":
+		*e = Arcgislicensetype_LiteUT
+	case "standardUT":
+		*e = Arcgislicensetype_StandardUT
+	case "storytellerUT":
+		*e = Arcgislicensetype_StorytellerUT
+	case "viewerUT":
+		*e = Arcgislicensetype_ViewerUT
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Arcgislicensetype enum")
+	}
+
+	return nil
+}
+
+func (e Arcgislicensetype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/audiodatatype.go

@@ -0,0 +1,53 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Audiodatatype string
+
+const (
+	Audiodatatype_Raw           Audiodatatype = "raw"
+	Audiodatatype_RawNormalized Audiodatatype = "raw_normalized"
+	Audiodatatype_Ogg           Audiodatatype = "ogg"
+)
+
+var AudiodatatypeAllValues = []Audiodatatype{
+	Audiodatatype_Raw,
+	Audiodatatype_RawNormalized,
+	Audiodatatype_Ogg,
+}
+
+func (e *Audiodatatype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "raw":
+		*e = Audiodatatype_Raw
+	case "raw_normalized":
+		*e = Audiodatatype_RawNormalized
+	case "ogg":
+		*e = Audiodatatype_Ogg
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Audiodatatype enum")
+	}
+
+	return nil
+}
+
+func (e Audiodatatype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/communication.go

@@ -0,0 +1,24 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type Communication struct {
+	Created            time.Time
+	ID                 int32 `sql:"primary_key"`
+	OrganizationID     int32
+	ResponseEmailLogID *int32
+	ResponseTextLogID  *int32
+	SourceEmailLogID   *int32
+	SourceReportID     *int32
+	SourceTextLogID    *int32
+	Status             Communicationstatus
+}

db/gen/nidus-sync/public/model/communication_log_entry.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type CommunicationLogEntry struct {
+	CommunicationID int32
+	Created         time.Time
+	ID              int32 `sql:"primary_key"`
+	Type            Communicationlogentry
+	User            *int32
+}

db/gen/nidus-sync/public/model/communicationlogentry.go

@@ -0,0 +1,69 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Communicationlogentry string
+
+const (
+	Communicationlogentry_Created                Communicationlogentry = "created"
+	Communicationlogentry_StatusClosed           Communicationlogentry = "status.closed"
+	Communicationlogentry_StatusInvalidated      Communicationlogentry = "status.invalidated"
+	Communicationlogentry_StatusOpened           Communicationlogentry = "status.opened"
+	Communicationlogentry_StatusPending          Communicationlogentry = "status.pending"
+	Communicationlogentry_StatusPossibleIssue    Communicationlogentry = "status.possible-issue"
+	Communicationlogentry_StatusPossibleResolved Communicationlogentry = "status.possible-resolved"
+)
+
+var CommunicationlogentryAllValues = []Communicationlogentry{
+	Communicationlogentry_Created,
+	Communicationlogentry_StatusClosed,
+	Communicationlogentry_StatusInvalidated,
+	Communicationlogentry_StatusOpened,
+	Communicationlogentry_StatusPending,
+	Communicationlogentry_StatusPossibleIssue,
+	Communicationlogentry_StatusPossibleResolved,
+}
+
+func (e *Communicationlogentry) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "created":
+		*e = Communicationlogentry_Created
+	case "status.closed":
+		*e = Communicationlogentry_StatusClosed
+	case "status.invalidated":
+		*e = Communicationlogentry_StatusInvalidated
+	case "status.opened":
+		*e = Communicationlogentry_StatusOpened
+	case "status.pending":
+		*e = Communicationlogentry_StatusPending
+	case "status.possible-issue":
+		*e = Communicationlogentry_StatusPossibleIssue
+	case "status.possible-resolved":
+		*e = Communicationlogentry_StatusPossibleResolved
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Communicationlogentry enum")
+	}
+
+	return nil
+}
+
+func (e Communicationlogentry) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/communicationstatus.go

@@ -0,0 +1,73 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Communicationstatus string
+
+const (
+	Communicationstatus_Closed           Communicationstatus = "closed"
+	Communicationstatus_Invalid          Communicationstatus = "invalid"
+	Communicationstatus_New              Communicationstatus = "new"
+	Communicationstatus_Opened           Communicationstatus = "opened"
+	Communicationstatus_Pending          Communicationstatus = "pending"
+	Communicationstatus_PossibleIssue    Communicationstatus = "possible-issue"
+	Communicationstatus_PossibleResolved Communicationstatus = "possible-resolved"
+	Communicationstatus_Resolved         Communicationstatus = "resolved"
+)
+
+var CommunicationstatusAllValues = []Communicationstatus{
+	Communicationstatus_Closed,
+	Communicationstatus_Invalid,
+	Communicationstatus_New,
+	Communicationstatus_Opened,
+	Communicationstatus_Pending,
+	Communicationstatus_PossibleIssue,
+	Communicationstatus_PossibleResolved,
+	Communicationstatus_Resolved,
+}
+
+func (e *Communicationstatus) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "closed":
+		*e = Communicationstatus_Closed
+	case "invalid":
+		*e = Communicationstatus_Invalid
+	case "new":
+		*e = Communicationstatus_New
+	case "opened":
+		*e = Communicationstatus_Opened
+	case "pending":
+		*e = Communicationstatus_Pending
+	case "possible-issue":
+		*e = Communicationstatus_PossibleIssue
+	case "possible-resolved":
+		*e = Communicationstatus_PossibleResolved
+	case "resolved":
+		*e = Communicationstatus_Resolved
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Communicationstatus enum")
+	}
+
+	return nil
+}
+
+func (e Communicationstatus) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/communicationstatustype.go

@@ -0,0 +1,73 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Communicationstatustype string
+
+const (
+	Communicationstatustype_Closed           Communicationstatustype = "closed"
+	Communicationstatustype_Invalid          Communicationstatustype = "invalid"
+	Communicationstatustype_New              Communicationstatustype = "new"
+	Communicationstatustype_Opened           Communicationstatustype = "opened"
+	Communicationstatustype_Pending          Communicationstatustype = "pending"
+	Communicationstatustype_PossibleIssue    Communicationstatustype = "possible-issue"
+	Communicationstatustype_PossibleResolved Communicationstatustype = "possible-resolved"
+	Communicationstatustype_Resolved         Communicationstatustype = "resolved"
+)
+
+var CommunicationstatustypeAllValues = []Communicationstatustype{
+	Communicationstatustype_Closed,
+	Communicationstatustype_Invalid,
+	Communicationstatustype_New,
+	Communicationstatustype_Opened,
+	Communicationstatustype_Pending,
+	Communicationstatustype_PossibleIssue,
+	Communicationstatustype_PossibleResolved,
+	Communicationstatustype_Resolved,
+}
+
+func (e *Communicationstatustype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "closed":
+		*e = Communicationstatustype_Closed
+	case "invalid":
+		*e = Communicationstatustype_Invalid
+	case "new":
+		*e = Communicationstatustype_New
+	case "opened":
+		*e = Communicationstatustype_Opened
+	case "pending":
+		*e = Communicationstatustype_Pending
+	case "possible-issue":
+		*e = Communicationstatustype_PossibleIssue
+	case "possible-resolved":
+		*e = Communicationstatustype_PossibleResolved
+	case "resolved":
+		*e = Communicationstatustype_Resolved
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Communicationstatustype enum")
+	}
+
+	return nil
+}
+
+func (e Communicationstatustype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/compliance_report_request.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type ComplianceReportRequest struct {
+	Created  time.Time
+	Creator  int32
+	ID       int32 `sql:"primary_key"`
+	PublicID string
+	LeadID   *int32
+}

db/gen/nidus-sync/public/model/compliance_report_request_mailer.go

@@ -0,0 +1,14 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type ComplianceReportRequestMailer struct {
+	ComplianceReportRequestID int32
+	MailerID                  int32
+	ID                        int32 `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/district_subscription_email.go

@@ -0,0 +1,13 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type DistrictSubscriptionEmail struct {
+	OrganizationID      int32  `sql:"primary_key"`
+	EmailContactAddress string `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/district_subscription_phone.go

@@ -0,0 +1,13 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type DistrictSubscriptionPhone struct {
+	OrganizationID int32  `sql:"primary_key"`
+	PhoneE164      string `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/feature.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+	"time"
+)
+
+type Feature struct {
+	Created        time.Time
+	CreatorID      int32
+	ID             int32 `sql:"primary_key"`
+	OrganizationID int32
+	SiteID         int32
+	Location       *geom.T
+}

db/gen/nidus-sync/public/model/feature_pool.go

@@ -0,0 +1,19 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+)
+
+type FeaturePool struct {
+	FeatureID   int32 `sql:"primary_key"`
+	Condition   Poolconditiontype
+	DepthMeters *float64
+	Geometry    *geom.T
+}

db/gen/nidus-sync/public/model/fieldseeker_sync.go

@@ -0,0 +1,21 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type FieldseekerSync struct {
+	ID               int32 `sql:"primary_key"`
+	Created          time.Time
+	RecordsCreated   int32
+	RecordsUpdated   int32
+	RecordsUnchanged int32
+	OrganizationID   int32
+}

db/gen/nidus-sync/public/model/geography_columns.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type GeographyColumns struct {
+	FTableCatalog    *string
+	FTableSchema     *string
+	FTableName       *string
+	FGeographyColumn *string
+	CoordDimension   *int32
+	Srid             *int32
+	Type             *string
+}

db/gen/nidus-sync/public/model/geometry_columns.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type GeometryColumns struct {
+	FTableCatalog   *string
+	FTableSchema    *string
+	FTableName      *string
+	FGeometryColumn *string
+	CoordDimension  *int32
+	Srid            *int32
+	Type            *string
+}

db/gen/nidus-sync/public/model/goose_db_version.go

@@ -0,0 +1,19 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type GooseDbVersion struct {
+	ID        int32 `sql:"primary_key"`
+	VersionID int64
+	IsApplied bool
+	Tstamp    time.Time
+}

db/gen/nidus-sync/public/model/h3_aggregation.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+)
+
+type H3Aggregation struct {
+	ID             int32 `sql:"primary_key"`
+	Cell           string
+	Count          int32
+	Geometry       *geom.T
+	OrganizationID int32
+	Resolution     int32
+	Type           H3aggregationtype
+}

db/gen/nidus-sync/public/model/h3aggregationtype.go

@@ -0,0 +1,53 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type H3aggregationtype string
+
+const (
+	H3aggregationtype_MosquitoSource H3aggregationtype = "MosquitoSource"
+	H3aggregationtype_ServiceRequest H3aggregationtype = "ServiceRequest"
+	H3aggregationtype_Trap           H3aggregationtype = "Trap"
+)
+
+var H3aggregationtypeAllValues = []H3aggregationtype{
+	H3aggregationtype_MosquitoSource,
+	H3aggregationtype_ServiceRequest,
+	H3aggregationtype_Trap,
+}
+
+func (e *H3aggregationtype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "MosquitoSource":
+		*e = H3aggregationtype_MosquitoSource
+	case "ServiceRequest":
+		*e = H3aggregationtype_ServiceRequest
+	case "Trap":
+		*e = H3aggregationtype_Trap
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for H3aggregationtype enum")
+	}
+
+	return nil
+}
+
+func (e H3aggregationtype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/hashtype.go

@@ -0,0 +1,45 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Hashtype string
+
+const (
+	Hashtype_Bcrypt14 Hashtype = "bcrypt-14"
+)
+
+var HashtypeAllValues = []Hashtype{
+	Hashtype_Bcrypt14,
+}
+
+func (e *Hashtype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "bcrypt-14":
+		*e = Hashtype_Bcrypt14
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Hashtype enum")
+	}
+
+	return nil
+}
+
+func (e Hashtype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/imagedatatype.go

@@ -0,0 +1,49 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Imagedatatype string
+
+const (
+	Imagedatatype_Raw Imagedatatype = "raw"
+	Imagedatatype_Png Imagedatatype = "png"
+)
+
+var ImagedatatypeAllValues = []Imagedatatype{
+	Imagedatatype_Raw,
+	Imagedatatype_Png,
+}
+
+func (e *Imagedatatype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "raw":
+		*e = Imagedatatype_Raw
+	case "png":
+		*e = Imagedatatype_Png
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Imagedatatype enum")
+	}
+
+	return nil
+}
+
+func (e Imagedatatype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/job.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+// A temporary holding place for jobs that are pushed to backend workers. Once work is completed the job should be deleted
+type Job struct {
+	Created time.Time
+	ID      int32 `sql:"primary_key"`
+	Type    Jobtype
+	RowID   int32
+}

db/gen/nidus-sync/public/model/jobtype.go

@@ -0,0 +1,73 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Jobtype string
+
+const (
+	Jobtype_AudioTranscode         Jobtype = "audio-transcode"
+	Jobtype_CsvCommit              Jobtype = "csv-commit"
+	Jobtype_CsvImport              Jobtype = "csv-import"
+	Jobtype_LabelStudioAudioCreate Jobtype = "label-studio-audio-create"
+	Jobtype_EmailSend              Jobtype = "email-send"
+	Jobtype_TextRespond            Jobtype = "text-respond"
+	Jobtype_TextSend               Jobtype = "text-send"
+	Jobtype_ComplianceMailerSend   Jobtype = "compliance-mailer-send"
+)
+
+var JobtypeAllValues = []Jobtype{
+	Jobtype_AudioTranscode,
+	Jobtype_CsvCommit,
+	Jobtype_CsvImport,
+	Jobtype_LabelStudioAudioCreate,
+	Jobtype_EmailSend,
+	Jobtype_TextRespond,
+	Jobtype_TextSend,
+	Jobtype_ComplianceMailerSend,
+}
+
+func (e *Jobtype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "audio-transcode":
+		*e = Jobtype_AudioTranscode
+	case "csv-commit":
+		*e = Jobtype_CsvCommit
+	case "csv-import":
+		*e = Jobtype_CsvImport
+	case "label-studio-audio-create":
+		*e = Jobtype_LabelStudioAudioCreate
+	case "email-send":
+		*e = Jobtype_EmailSend
+	case "text-respond":
+		*e = Jobtype_TextRespond
+	case "text-send":
+		*e = Jobtype_TextSend
+	case "compliance-mailer-send":
+		*e = Jobtype_ComplianceMailerSend
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Jobtype enum")
+	}
+
+	return nil
+}
+
+func (e Jobtype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/lead.go

@@ -0,0 +1,21 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type Lead struct {
+	Created        time.Time
+	Creator        int32
+	ID             int32 `sql:"primary_key"`
+	OrganizationID int32
+	SiteID         *int32
+	Type           Leadtype
+}

db/gen/nidus-sync/public/model/leadtype.go

@@ -0,0 +1,57 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Leadtype string
+
+const (
+	Leadtype_Unknown              Leadtype = "unknown"
+	Leadtype_GreenPool            Leadtype = "green-pool"
+	Leadtype_PublicreportNuisance Leadtype = "publicreport-nuisance"
+	Leadtype_PublicreportWater    Leadtype = "publicreport-water"
+)
+
+var LeadtypeAllValues = []Leadtype{
+	Leadtype_Unknown,
+	Leadtype_GreenPool,
+	Leadtype_PublicreportNuisance,
+	Leadtype_PublicreportWater,
+}
+
+func (e *Leadtype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "unknown":
+		*e = Leadtype_Unknown
+	case "green-pool":
+		*e = Leadtype_GreenPool
+	case "publicreport-nuisance":
+		*e = Leadtype_PublicreportNuisance
+	case "publicreport-water":
+		*e = Leadtype_PublicreportWater
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Leadtype enum")
+	}
+
+	return nil
+}
+
+func (e Leadtype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/log_impersonation.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type LogImpersonation struct {
+	BeginAt        time.Time
+	EndAt          *time.Time
+	ID             int32 `sql:"primary_key"`
+	ImpersonatorID int32
+	TargetID       int32
+}

db/gen/nidus-sync/public/model/mosquitospecies.go

@@ -0,0 +1,61 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Mosquitospecies string
+
+const (
+	Mosquitospecies_None            Mosquitospecies = "none"
+	Mosquitospecies_AedesAegypti    Mosquitospecies = "aedes aegypti"
+	Mosquitospecies_AedesAlbopictus Mosquitospecies = "aedes albopictus"
+	Mosquitospecies_CulexPipiens    Mosquitospecies = "culex pipiens"
+	Mosquitospecies_CulexTarsalis   Mosquitospecies = "culex tarsalis"
+)
+
+var MosquitospeciesAllValues = []Mosquitospecies{
+	Mosquitospecies_None,
+	Mosquitospecies_AedesAegypti,
+	Mosquitospecies_AedesAlbopictus,
+	Mosquitospecies_CulexPipiens,
+	Mosquitospecies_CulexTarsalis,
+}
+
+func (e *Mosquitospecies) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "none":
+		*e = Mosquitospecies_None
+	case "aedes aegypti":
+		*e = Mosquitospecies_AedesAegypti
+	case "aedes albopictus":
+		*e = Mosquitospecies_AedesAlbopictus
+	case "culex pipiens":
+		*e = Mosquitospecies_CulexPipiens
+	case "culex tarsalis":
+		*e = Mosquitospecies_CulexTarsalis
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Mosquitospecies enum")
+	}
+
+	return nil
+}
+
+func (e Mosquitospecies) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/note_audio.go

@@ -0,0 +1,27 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type NoteAudio struct {
+	Created                 time.Time
+	CreatorID               int32
+	Deleted                 *time.Time
+	DeletorID               *int32
+	Duration                float32
+	OrganizationID          int32
+	Transcription           *string
+	TranscriptionUserEdited bool
+	Version                 int32     `sql:"primary_key"`
+	UUID                    uuid.UUID `sql:"primary_key"`
+	ID                      int32
+}

db/gen/nidus-sync/public/model/note_audio_breadcrumb.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type NoteAudioBreadcrumb struct {
+	Cell             string
+	Created          time.Time
+	ManuallySelected bool
+	NoteAudioVersion int32     `sql:"primary_key"`
+	NoteAudioUUID    uuid.UUID `sql:"primary_key"`
+	Position         int32     `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/note_audio_data.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type NoteAudioData struct {
+	Created          time.Time
+	NoteAudioVersion int32         `sql:"primary_key"`
+	NoteAudioUUID    uuid.UUID     `sql:"primary_key"`
+	Type             Audiodatatype `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/note_image.go

@@ -0,0 +1,24 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type NoteImage struct {
+	Created        time.Time
+	CreatorID      int32
+	Deleted        *time.Time
+	DeletorID      *int32
+	OrganizationID int32
+	Version        int32     `sql:"primary_key"`
+	UUID           uuid.UUID `sql:"primary_key"`
+	ID             int32
+}

db/gen/nidus-sync/public/model/note_image_breadcrumb.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type NoteImageBreadcrumb struct {
+	Cell             string
+	Created          time.Time
+	ManuallySelected bool
+	NoteImageVersion int32     `sql:"primary_key"`
+	NoteImageUUID    uuid.UUID `sql:"primary_key"`
+	Position         int32     `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/note_image_data.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type NoteImageData struct {
+	Created          time.Time
+	NoteImageVersion int32         `sql:"primary_key"`
+	NoteImageUUID    uuid.UUID     `sql:"primary_key"`
+	Type             Audiodatatype `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/notification.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type Notification struct {
+	ID         int32 `sql:"primary_key"`
+	Created    time.Time
+	Link       string
+	Message    string
+	Type       Notificationtype
+	UserID     int32
+	ResolvedAt *time.Time
+}

db/gen/nidus-sync/public/model/notificationtype.go

@@ -0,0 +1,45 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Notificationtype string
+
+const (
+	Notificationtype_OAuthTokenInvalidated Notificationtype = "oauth_token_invalidated"
+)
+
+var NotificationtypeAllValues = []Notificationtype{
+	Notificationtype_OAuthTokenInvalidated,
+}
+
+func (e *Notificationtype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "oauth_token_invalidated":
+		*e = Notificationtype_OAuthTokenInvalidated
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Notificationtype enum")
+	}
+
+	return nil
+}
+
+func (e Notificationtype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/organization.go

@@ -0,0 +1,51 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"github.com/twpayne/go-geom"
+)
+
+type Organization struct {
+	ID                              int32 `sql:"primary_key"`
+	Name                            string
+	ImportDistrictGid               *int32
+	Website                         *string
+	LogoUUID                        *uuid.UUID
+	Slug                            *string
+	GeneralManagerName              *string
+	MailingAddressCity              *string
+	MailingAddressPostalCode        *string
+	MailingAddressStreet            *string
+	OfficeAddressCity               *string
+	OfficeAddressPostalCode         *string
+	OfficeAddressStreet             *string
+	ServiceAreaGeometry             *geom.T
+	ServiceAreaSquareMeters         *float64
+	ServiceAreaCentroid             *geom.T
+	ServiceAreaExtent               *geom.T
+	OfficeFax                       *string
+	OfficePhone                     *string
+	ServiceAreaXmin                 *float64
+	ServiceAreaYmin                 *float64
+	ServiceAreaXmax                 *float64
+	ServiceAreaYmax                 *float64
+	ServiceAreaCentroidGeojson      *string
+	ServiceAreaCentroidX            *float64
+	ServiceAreaCentroidY            *float64
+	MailingAddressCountry           *string
+	MailingAddressState             *string
+	OfficeAddressCountry            *string
+	OfficeAddressState              *string
+	ArcgisAccountID                 *string
+	FieldseekerServiceFeatureItemID *string
+	ArcgisMapServiceID              *string
+	IsCatchall                      bool
+	LobAddressID                    *string
+}

db/gen/nidus-sync/public/model/parcel.go

@@ -0,0 +1,19 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+)
+
+type Parcel struct {
+	Apn         *string
+	Description *string
+	ID          int32 `sql:"primary_key"`
+	Geometry    geom.T
+}

db/gen/nidus-sync/public/model/poolconditiontype.go

@@ -0,0 +1,65 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Poolconditiontype string
+
+const (
+	Poolconditiontype_Blue      Poolconditiontype = "blue"
+	Poolconditiontype_Dry       Poolconditiontype = "dry"
+	Poolconditiontype_FalsePool Poolconditiontype = "false pool"
+	Poolconditiontype_Unknown   Poolconditiontype = "unknown"
+	Poolconditiontype_Green     Poolconditiontype = "green"
+	Poolconditiontype_Murky     Poolconditiontype = "murky"
+)
+
+var PoolconditiontypeAllValues = []Poolconditiontype{
+	Poolconditiontype_Blue,
+	Poolconditiontype_Dry,
+	Poolconditiontype_FalsePool,
+	Poolconditiontype_Unknown,
+	Poolconditiontype_Green,
+	Poolconditiontype_Murky,
+}
+
+func (e *Poolconditiontype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "blue":
+		*e = Poolconditiontype_Blue
+	case "dry":
+		*e = Poolconditiontype_Dry
+	case "false pool":
+		*e = Poolconditiontype_FalsePool
+	case "unknown":
+		*e = Poolconditiontype_Unknown
+	case "green":
+		*e = Poolconditiontype_Green
+	case "murky":
+		*e = Poolconditiontype_Murky
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Poolconditiontype enum")
+	}
+
+	return nil
+}
+
+func (e Poolconditiontype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/raster_columns.go

@@ -0,0 +1,32 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/lib/pq"
+)
+
+type RasterColumns struct {
+	RTableCatalog   *string
+	RTableSchema    *string
+	RTableName      *string
+	RRasterColumn   *string
+	Srid            *int32
+	ScaleX          *float64
+	ScaleY          *float64
+	BlocksizeX      *int32
+	BlocksizeY      *int32
+	SameAlignment   *bool
+	RegularBlocking *bool
+	NumBands        *int32
+	PixelTypes      *pq.StringArray
+	NodataValues    *pq.Float64Array
+	OutDb           *pq.BoolArray
+	Extent          *string
+	SpatialIndex    *bool
+}

db/gen/nidus-sync/public/model/raster_overviews.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type RasterOverviews struct {
+	OTableCatalog  *string
+	OTableSchema   *string
+	OTableName     *string
+	ORasterColumn  *string
+	RTableCatalog  *string
+	RTableSchema   *string
+	RTableName     *string
+	RRasterColumn  *string
+	OverviewFactor *int32
+}

db/gen/nidus-sync/public/model/report_text.go

@@ -0,0 +1,14 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type ReportText struct {
+	CreatorID int32 `sql:"primary_key"`
+	ReportID  int32 `sql:"primary_key"`
+	TextLogID int32 `sql:"primary_key"`
+}

db/gen/nidus-sync/public/model/resident.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type Resident struct {
+	AddressID   int32
+	Created     time.Time
+	Creator     int32
+	ID          int32 `sql:"primary_key"`
+	Name        string
+	PhoneMobile *string
+	SiteID      int32
+}

db/gen/nidus-sync/public/model/review_task.go

@@ -0,0 +1,22 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type ReviewTask struct {
+	Created        time.Time
+	CreatorID      *int32
+	ID             int32 `sql:"primary_key"`
+	OrganizationID int32
+	Reviewed       *time.Time
+	ReviewerID     *int32
+	Resolution     *Reviewtaskresolutiontype
+}

db/gen/nidus-sync/public/model/review_task_pool.go

@@ -0,0 +1,20 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+)
+
+type ReviewTaskPool struct {
+	FeaturePoolID int32
+	Location      *geom.T
+	Geometry      *geom.T
+	ReviewTaskID  int32 `sql:"primary_key"`
+	Condition     *Poolconditiontype
+}

db/gen/nidus-sync/public/model/reviewtaskresolutiontype.go

@@ -0,0 +1,49 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Reviewtaskresolutiontype string
+
+const (
+	Reviewtaskresolutiontype_Committed Reviewtaskresolutiontype = "committed"
+	Reviewtaskresolutiontype_Discarded Reviewtaskresolutiontype = "discarded"
+)
+
+var ReviewtaskresolutiontypeAllValues = []Reviewtaskresolutiontype{
+	Reviewtaskresolutiontype_Committed,
+	Reviewtaskresolutiontype_Discarded,
+}
+
+func (e *Reviewtaskresolutiontype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "committed":
+		*e = Reviewtaskresolutiontype_Committed
+	case "discarded":
+		*e = Reviewtaskresolutiontype_Discarded
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Reviewtaskresolutiontype enum")
+	}
+
+	return nil
+}
+
+func (e Reviewtaskresolutiontype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/sessions.go

@@ -0,0 +1,18 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type Sessions struct {
+	Token  string `sql:"primary_key"`
+	Data   []byte
+	Expiry time.Time
+}

db/gen/nidus-sync/public/model/signal.go

@@ -0,0 +1,28 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/twpayne/go-geom"
+	"time"
+)
+
+type Signal struct {
+	Addressed            *time.Time
+	Addressor            *int32
+	Created              time.Time
+	Creator              int32
+	ID                   int32 `sql:"primary_key"`
+	OrganizationID       int32
+	Species              *Mosquitospecies
+	Type                 Signaltype
+	SiteID               *int32
+	Location             geom.T
+	FeaturePoolFeatureID *int32
+	ReportID             *int32
+}

db/gen/nidus-sync/public/model/signaltype.go

@@ -0,0 +1,69 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Signaltype string
+
+const (
+	Signaltype_FlyoverPool             Signaltype = "flyover pool"
+	Signaltype_PlanFollowup            Signaltype = "plan followup"
+	Signaltype_PublicreportWater       Signaltype = "publicreport water"
+	Signaltype_PublicreportNuisance    Signaltype = "publicreport nuisance"
+	Signaltype_ResidualExiring         Signaltype = "residual exiring"
+	Signaltype_SurveillanceObservation Signaltype = "surveillance observation"
+	Signaltype_TrapSpike               Signaltype = "trap spike"
+)
+
+var SignaltypeAllValues = []Signaltype{
+	Signaltype_FlyoverPool,
+	Signaltype_PlanFollowup,
+	Signaltype_PublicreportWater,
+	Signaltype_PublicreportNuisance,
+	Signaltype_ResidualExiring,
+	Signaltype_SurveillanceObservation,
+	Signaltype_TrapSpike,
+}
+
+func (e *Signaltype) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "flyover pool":
+		*e = Signaltype_FlyoverPool
+	case "plan followup":
+		*e = Signaltype_PlanFollowup
+	case "publicreport water":
+		*e = Signaltype_PublicreportWater
+	case "publicreport nuisance":
+		*e = Signaltype_PublicreportNuisance
+	case "residual exiring":
+		*e = Signaltype_ResidualExiring
+	case "surveillance observation":
+		*e = Signaltype_SurveillanceObservation
+	case "trap spike":
+		*e = Signaltype_TrapSpike
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Signaltype enum")
+	}
+
+	return nil
+}
+
+func (e Signaltype) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/model/site.go

@@ -0,0 +1,28 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"time"
+)
+
+type Site struct {
+	AddressID      int32
+	Created        time.Time
+	CreatorID      int32
+	FileID         *int32
+	ID             int32 `sql:"primary_key"`
+	Notes          string
+	OrganizationID int32
+	OwnerName      string
+	OwnerPhoneE164 *string
+	ParcelID       *int32
+	ResidentOwned  *bool
+	Tags           string
+	Version        int32
+}

db/gen/nidus-sync/public/model/spatial_ref_sys.go

@@ -0,0 +1,16 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+type SpatialRefSys struct {
+	Srid      int32 `sql:"primary_key"`
+	AuthName  *string
+	AuthSrid  *int32
+	Srtext    *string
+	Proj4text *string
+}

db/gen/nidus-sync/public/model/user_.go

@@ -0,0 +1,33 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import (
+	"github.com/google/uuid"
+	"time"
+)
+
+type User struct {
+	ID                        int32 `sql:"primary_key"`
+	ArcgisAccessToken         *string
+	ArcgisLicense             *Arcgislicensetype
+	ArcgisRefreshToken        *string
+	ArcgisRefreshTokenExpires *time.Time
+	ArcgisRole                *string
+	DisplayName               string
+	Email                     *string
+	OrganizationID            int32
+	Username                  string
+	PasswordHashType          Hashtype
+	PasswordHash              string
+	Role                      Userrole
+	Avatar                    *uuid.UUID
+	IsActive                  bool
+	IsDronePilot              bool
+	IsWarrant                 bool
+}

db/gen/nidus-sync/public/model/userrole.go

@@ -0,0 +1,49 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package model
+
+import "errors"
+
+type Userrole string
+
+const (
+	Userrole_Root         Userrole = "root"
+	Userrole_AccountOwner Userrole = "account-owner"
+)
+
+var UserroleAllValues = []Userrole{
+	Userrole_Root,
+	Userrole_AccountOwner,
+}
+
+func (e *Userrole) Scan(value interface{}) error {
+	var enumValue string
+	switch val := value.(type) {
+	case string:
+		enumValue = val
+	case []byte:
+		enumValue = string(val)
+	default:
+		return errors.New("jet: Invalid scan value for AllTypesEnum enum. Enum value has to be of type string or []byte")
+	}
+
+	switch enumValue {
+	case "root":
+		*e = Userrole_Root
+	case "account-owner":
+		*e = Userrole_AccountOwner
+	default:
+		return errors.New("jet: Invalid scan value '" + enumValue + "' for Userrole enum")
+	}
+
+	return nil
+}
+
+func (e Userrole) String() string {
+	return string(e)
+}

db/gen/nidus-sync/public/table/address.go

@@ -0,0 +1,111 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var Address = newAddressTable("public", "address", "")
+
+type addressTable struct {
+	postgres.Table
+
+	// Columns
+	Country    postgres.ColumnString
+	Created    postgres.ColumnTimestamp
+	Location   postgres.ColumnGeometry
+	H3cell     postgres.ColumnString
+	ID         postgres.ColumnInteger
+	Locality   postgres.ColumnString
+	PostalCode postgres.ColumnString
+	Street     postgres.ColumnString
+	Unit       postgres.ColumnString
+	Region     postgres.ColumnString
+	Number     postgres.ColumnString
+	Gid        postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type AddressTable struct {
+	addressTable
+
+	EXCLUDED addressTable
+}
+
+// AS creates new AddressTable with assigned alias
+func (a AddressTable) AS(alias string) *AddressTable {
+	return newAddressTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new AddressTable with assigned schema name
+func (a AddressTable) FromSchema(schemaName string) *AddressTable {
+	return newAddressTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new AddressTable with assigned table prefix
+func (a AddressTable) WithPrefix(prefix string) *AddressTable {
+	return newAddressTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new AddressTable with assigned table suffix
+func (a AddressTable) WithSuffix(suffix string) *AddressTable {
+	return newAddressTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newAddressTable(schemaName, tableName, alias string) *AddressTable {
+	return &AddressTable{
+		addressTable: newAddressTableImpl(schemaName, tableName, alias),
+		EXCLUDED:     newAddressTableImpl("", "excluded", ""),
+	}
+}
+
+func newAddressTableImpl(schemaName, tableName, alias string) addressTable {
+	var (
+		CountryColumn    = postgres.StringColumn("country")
+		CreatedColumn    = postgres.TimestampColumn("created")
+		LocationColumn   = postgres.GeometryColumn("location")
+		H3cellColumn     = postgres.StringColumn("h3cell")
+		IDColumn         = postgres.IntegerColumn("id")
+		LocalityColumn   = postgres.StringColumn("locality")
+		PostalCodeColumn = postgres.StringColumn("postal_code")
+		StreetColumn     = postgres.StringColumn("street")
+		UnitColumn       = postgres.StringColumn("unit")
+		RegionColumn     = postgres.StringColumn("region")
+		NumberColumn     = postgres.StringColumn("number_")
+		GidColumn        = postgres.StringColumn("gid")
+		allColumns       = postgres.ColumnList{CountryColumn, CreatedColumn, LocationColumn, H3cellColumn, IDColumn, LocalityColumn, PostalCodeColumn, StreetColumn, UnitColumn, RegionColumn, NumberColumn, GidColumn}
+		mutableColumns   = postgres.ColumnList{CountryColumn, CreatedColumn, LocationColumn, H3cellColumn, LocalityColumn, PostalCodeColumn, StreetColumn, UnitColumn, RegionColumn, NumberColumn, GidColumn}
+		defaultColumns   = postgres.ColumnList{IDColumn}
+	)
+
+	return addressTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Country:    CountryColumn,
+		Created:    CreatedColumn,
+		Location:   LocationColumn,
+		H3cell:     H3cellColumn,
+		ID:         IDColumn,
+		Locality:   LocalityColumn,
+		PostalCode: PostalCodeColumn,
+		Street:     StreetColumn,
+		Unit:       UnitColumn,
+		Region:     RegionColumn,
+		Number:     NumberColumn,
+		Gid:        GidColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}

db/gen/nidus-sync/public/table/communication.go

@@ -0,0 +1,102 @@
+//
+// Code generated by go-jet DO NOT EDIT.
+//
+// WARNING: Changes to this file may cause incorrect behavior
+// and will be lost if the code is regenerated
+//
+
+package table
+
+import (
+	"github.com/Gleipnir-Technology/jet/postgres"
+)
+
+var Communication = newCommunicationTable("public", "communication", "")
+
+type communicationTable struct {
+	postgres.Table
+
+	// Columns
+	Created            postgres.ColumnTimestamp
+	ID                 postgres.ColumnInteger
+	OrganizationID     postgres.ColumnInteger
+	ResponseEmailLogID postgres.ColumnInteger
+	ResponseTextLogID  postgres.ColumnInteger
+	SourceEmailLogID   postgres.ColumnInteger
+	SourceReportID     postgres.ColumnInteger
+	SourceTextLogID    postgres.ColumnInteger
+	Status             postgres.ColumnString
+
+	AllColumns     postgres.ColumnList
+	MutableColumns postgres.ColumnList
+	DefaultColumns postgres.ColumnList
+}
+
+type CommunicationTable struct {
+	communicationTable
+
+	EXCLUDED communicationTable
+}
+
+// AS creates new CommunicationTable with assigned alias
+func (a CommunicationTable) AS(alias string) *CommunicationTable {
+	return newCommunicationTable(a.SchemaName(), a.TableName(), alias)
+}
+
+// Schema creates new CommunicationTable with assigned schema name
+func (a CommunicationTable) FromSchema(schemaName string) *CommunicationTable {
+	return newCommunicationTable(schemaName, a.TableName(), a.Alias())
+}
+
+// WithPrefix creates new CommunicationTable with assigned table prefix
+func (a CommunicationTable) WithPrefix(prefix string) *CommunicationTable {
+	return newCommunicationTable(a.SchemaName(), prefix+a.TableName(), a.TableName())
+}
+
+// WithSuffix creates new CommunicationTable with assigned table suffix
+func (a CommunicationTable) WithSuffix(suffix string) *CommunicationTable {
+	return newCommunicationTable(a.SchemaName(), a.TableName()+suffix, a.TableName())
+}
+
+func newCommunicationTable(schemaName, tableName, alias string) *CommunicationTable {
+	return &CommunicationTable{
+		communicationTable: newCommunicationTableImpl(schemaName, tableName, alias),
+		EXCLUDED:           newCommunicationTableImpl("", "excluded", ""),
+	}
+}
+
+func newCommunicationTableImpl(schemaName, tableName, alias string) communicationTable {
+	var (
+		CreatedColumn            = postgres.TimestampColumn("created")
+		IDColumn                 = postgres.IntegerColumn("id")
+		OrganizationIDColumn     = postgres.IntegerColumn("organization_id")
+		ResponseEmailLogIDColumn = postgres.IntegerColumn("response_email_log_id")
+		ResponseTextLogIDColumn  = postgres.IntegerColumn("response_text_log_id")
+		SourceEmailLogIDColumn   = postgres.IntegerColumn("source_email_log_id")
+		SourceReportIDColumn     = postgres.IntegerColumn("source_report_id")
+		SourceTextLogIDColumn    = postgres.IntegerColumn("source_text_log_id")
+		StatusColumn             = postgres.StringColumn("status")
+		allColumns               = postgres.ColumnList{CreatedColumn, IDColumn, OrganizationIDColumn, ResponseEmailLogIDColumn, ResponseTextLogIDColumn, SourceEmailLogIDColumn, SourceReportIDColumn, SourceTextLogIDColumn, StatusColumn}
+		mutableColumns           = postgres.ColumnList{CreatedColumn, OrganizationIDColumn, ResponseEmailLogIDColumn, ResponseTextLogIDColumn, SourceEmailLogIDColumn, SourceReportIDColumn, SourceTextLogIDColumn, StatusColumn}
+		defaultColumns           = postgres.ColumnList{IDColumn}
+	)
+
+	return communicationTable{
+		Table: postgres.NewTable(schemaName, tableName, alias, allColumns...),
+
+		//Columns
+		Created:            CreatedColumn,
+		ID:                 IDColumn,
+		OrganizationID:     OrganizationIDColumn,
+		ResponseEmailLogID: ResponseEmailLogIDColumn,
+		ResponseTextLogID:  ResponseTextLogIDColumn,
+		SourceEmailLogID:   SourceEmailLogIDColumn,
+		SourceReportID:     SourceReportIDColumn,
+		SourceTextLogID:    SourceTextLogIDColumn,
+		Status:             StatusColumn,
+
+		AllColumns:     allColumns,
+		MutableColumns: mutableColumns,
+		DefaultColumns: defaultColumns,
+	}
+}