Skip to content

Commit

Permalink
MF-1190 - Add pkg for library packages (#1191)
Browse files Browse the repository at this point in the history
* Move messaging to pkg

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Move errors to pkg

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Move Transformers to pkg

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Move SDK to pkg

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Remove Transformers from root

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Fix make proto

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Add copyrights header

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Fix CI

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Move Auth client to pkg

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Fix dependencies

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Update dependencies and vendors

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>

* Fix CI

Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com>
  • Loading branch information
dborovcanin committed Jun 3, 2020
1 parent c26c7f3 commit ea3a891
Show file tree
Hide file tree
Showing 393 changed files with 32,878 additions and 1,016 deletions.
2 changes: 1 addition & 1 deletion Makefile
Expand Up @@ -71,7 +71,7 @@ test:

proto:
protoc --gofast_out=plugins=grpc:. *.proto
protoc --gofast_out=plugins=grpc:. messaging/*.proto
protoc --gofast_out=plugins=grpc:. pkg/messaging/*.proto

$(SERVICES):
$(call compile_service,$(@))
Expand Down
2 changes: 1 addition & 1 deletion authn/api/grpc/server.go
Expand Up @@ -8,7 +8,7 @@ import (
kitgrpc "github.com/go-kit/kit/transport/grpc"
mainflux "github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
opentracing "github.com/opentracing/opentracing-go"
"golang.org/x/net/context"
"google.golang.org/grpc/codes"
Expand Down
2 changes: 1 addition & 1 deletion authn/api/http/transport.go
Expand Up @@ -15,7 +15,7 @@ import (
"github.com/go-zoo/bone"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/opentracing/opentracing-go"
"github.com/prometheus/client_golang/prometheus/promhttp"
)
Expand Down
2 changes: 1 addition & 1 deletion authn/jwt/token_test.go
Expand Up @@ -10,7 +10,7 @@ import (

"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/authn/jwt"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
)
Expand Down
2 changes: 1 addition & 1 deletion authn/jwt/tokenizer.go
Expand Up @@ -8,7 +8,7 @@ import (

"github.com/dgrijalva/jwt-go"
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
)

type claims struct {
Expand Down
2 changes: 1 addition & 1 deletion authn/postgres/key.go
Expand Up @@ -7,7 +7,7 @@ import (

"github.com/lib/pq"
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
)

var (
Expand Down
2 changes: 1 addition & 1 deletion authn/postgres/key_test.go
Expand Up @@ -12,7 +12,7 @@ import (
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/authn/postgres"
"github.com/mainflux/mainflux/authn/uuid"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/opentracing/opentracing-go"
"github.com/stretchr/testify/assert"
)
Expand Down
2 changes: 1 addition & 1 deletion authn/service.go
Expand Up @@ -7,7 +7,7 @@ import (
"context"
"time"

"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion authn/service_test.go
Expand Up @@ -12,7 +12,7 @@ import (
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/authn/jwt"
"github.com/mainflux/mainflux/authn/mocks"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/stretchr/testify/assert"
)

Expand Down
2 changes: 1 addition & 1 deletion authn/uuid/idp.go
Expand Up @@ -7,7 +7,7 @@ package uuid
import (
"github.com/gofrs/uuid"
"github.com/mainflux/mainflux/authn"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
)

// errGeneratingID indicates error in generating UUID
Expand Down
2 changes: 1 addition & 1 deletion bootstrap/api/endpoint_test.go
Expand Up @@ -22,7 +22,7 @@ import (
"github.com/mainflux/mainflux/bootstrap"
bsapi "github.com/mainflux/mainflux/bootstrap/api"
"github.com/mainflux/mainflux/bootstrap/mocks"
mfsdk "github.com/mainflux/mainflux/sdk/go"
mfsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/mainflux/mainflux/things"
thingsapi "github.com/mainflux/mainflux/things/api/things/http"
"github.com/opentracing/opentracing-go/mocktracer"
Expand Down
2 changes: 1 addition & 1 deletion bootstrap/api/transport.go
Expand Up @@ -16,7 +16,7 @@ import (
"github.com/go-zoo/bone"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/bootstrap"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/prometheus/client_golang/prometheus/promhttp"
)

Expand Down
2 changes: 1 addition & 1 deletion bootstrap/postgres/configs.go
Expand Up @@ -12,8 +12,8 @@ import (
"github.com/jmoiron/sqlx"
"github.com/lib/pq"
"github.com/mainflux/mainflux/bootstrap"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/pkg/errors"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion bootstrap/postgres/configs_test.go
Expand Up @@ -11,7 +11,7 @@ import (
"github.com/gofrs/uuid"
"github.com/mainflux/mainflux/bootstrap"
"github.com/mainflux/mainflux/bootstrap/postgres"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
)
Expand Down
4 changes: 2 additions & 2 deletions bootstrap/redis/producer/streams_test.go
Expand Up @@ -13,13 +13,13 @@ import (

"github.com/go-redis/redis"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/pkg/errors"
"github.com/opentracing/opentracing-go/mocktracer"

"github.com/mainflux/mainflux/bootstrap"
"github.com/mainflux/mainflux/bootstrap/mocks"
"github.com/mainflux/mainflux/bootstrap/redis/producer"
mfsdk "github.com/mainflux/mainflux/sdk/go"
mfsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/mainflux/mainflux/things"
httpapi "github.com/mainflux/mainflux/things/api/things/http"
"github.com/stretchr/testify/assert"
Expand Down
4 changes: 2 additions & 2 deletions bootstrap/service.go
Expand Up @@ -11,8 +11,8 @@ import (
"time"

"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/errors"
mfsdk "github.com/mainflux/mainflux/sdk/go"
"github.com/mainflux/mainflux/pkg/errors"
mfsdk "github.com/mainflux/mainflux/pkg/sdk/go"
)

var (
Expand Down
4 changes: 2 additions & 2 deletions bootstrap/service_test.go
Expand Up @@ -20,8 +20,8 @@ import (
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/bootstrap"
"github.com/mainflux/mainflux/bootstrap/mocks"
"github.com/mainflux/mainflux/errors"
mfsdk "github.com/mainflux/mainflux/sdk/go"
"github.com/mainflux/mainflux/pkg/errors"
mfsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/mainflux/mainflux/things"
httpapi "github.com/mainflux/mainflux/things/api/things/http"
"github.com/stretchr/testify/assert"
Expand Down
2 changes: 1 addition & 1 deletion cli/bootstrap.go
Expand Up @@ -6,7 +6,7 @@ package cli
import (
"encoding/json"

mfxsdk "github.com/mainflux/mainflux/sdk/go"
mfxsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/spf13/cobra"
)

Expand Down
2 changes: 1 addition & 1 deletion cli/channels.go
Expand Up @@ -6,7 +6,7 @@ package cli
import (
"encoding/json"

mfxsdk "github.com/mainflux/mainflux/sdk/go"
mfxsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/spf13/cobra"
)

Expand Down
2 changes: 1 addition & 1 deletion cli/provision.go
Expand Up @@ -13,7 +13,7 @@ import (
"path/filepath"

"github.com/docker/docker/pkg/namesgenerator"
mfxsdk "github.com/mainflux/mainflux/sdk/go"
mfxsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/spf13/cobra"
)

Expand Down
2 changes: 1 addition & 1 deletion cli/sdk.go
Expand Up @@ -3,7 +3,7 @@

package cli

import mfxsdk "github.com/mainflux/mainflux/sdk/go"
import mfxsdk "github.com/mainflux/mainflux/pkg/sdk/go"

// Keep SDK handle in global var
var sdk mfxsdk.SDK
Expand Down
2 changes: 1 addition & 1 deletion cli/things.go
Expand Up @@ -6,7 +6,7 @@ package cli
import (
"encoding/json"

mfxsdk "github.com/mainflux/mainflux/sdk/go"
mfxsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/spf13/cobra"
)

Expand Down
2 changes: 1 addition & 1 deletion cli/users.go
Expand Up @@ -6,7 +6,7 @@ package cli
import (
"encoding/json"

mfxsdk "github.com/mainflux/mainflux/sdk/go"
mfxsdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/spf13/cobra"
)

Expand Down
2 changes: 1 addition & 1 deletion cmd/bootstrap/main.go
Expand Up @@ -30,7 +30,7 @@ import (
api "github.com/mainflux/mainflux/bootstrap/api"
"github.com/mainflux/mainflux/bootstrap/postgres"
mflog "github.com/mainflux/mainflux/logger"
mfsdk "github.com/mainflux/mainflux/sdk/go"
mfsdk "github.com/mainflux/mainflux/pkg/sdk/go"
stdprometheus "github.com/prometheus/client_golang/prometheus"
jconfig "github.com/uber/jaeger-client-go/config"
"google.golang.org/grpc"
Expand Down
4 changes: 2 additions & 2 deletions cmd/cassandra-writer/main.go
Expand Up @@ -17,8 +17,8 @@ import (
"github.com/gocql/gocql"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/transformers/senml"
"github.com/mainflux/mainflux/pkg/messaging/nats"
"github.com/mainflux/mainflux/pkg/transformers/senml"
"github.com/mainflux/mainflux/writers"
"github.com/mainflux/mainflux/writers/api"
"github.com/mainflux/mainflux/writers/cassandra"
Expand Down
2 changes: 1 addition & 1 deletion cmd/cli/main.go
Expand Up @@ -7,7 +7,7 @@ import (
"log"

"github.com/mainflux/mainflux/cli"
"github.com/mainflux/mainflux/sdk/go"
sdk "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/spf13/cobra"
)

Expand Down
2 changes: 1 addition & 1 deletion cmd/coap/main.go
Expand Up @@ -21,7 +21,7 @@ import (
"github.com/mainflux/mainflux/coap"
"github.com/mainflux/mainflux/coap/api"
logger "github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/pkg/messaging/nats"
thingsapi "github.com/mainflux/mainflux/things/api/auth/grpc"
opentracing "github.com/opentracing/opentracing-go"
stdprometheus "github.com/prometheus/client_golang/prometheus"
Expand Down
2 changes: 1 addition & 1 deletion cmd/http/main.go
Expand Up @@ -22,7 +22,7 @@ import (
adapter "github.com/mainflux/mainflux/http"
"github.com/mainflux/mainflux/http/api"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/pkg/messaging/nats"
thingsapi "github.com/mainflux/mainflux/things/api/auth/grpc"
"github.com/opentracing/opentracing-go"
stdprometheus "github.com/prometheus/client_golang/prometheus"
Expand Down
4 changes: 2 additions & 2 deletions cmd/influxdb-writer/main.go
Expand Up @@ -15,8 +15,8 @@ import (
influxdata "github.com/influxdata/influxdb/client/v2"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/transformers/senml"
"github.com/mainflux/mainflux/pkg/messaging/nats"
"github.com/mainflux/mainflux/pkg/transformers/senml"
"github.com/mainflux/mainflux/writers"
"github.com/mainflux/mainflux/writers/api"
"github.com/mainflux/mainflux/writers/influxdb"
Expand Down
2 changes: 1 addition & 1 deletion cmd/lora/main.go
Expand Up @@ -19,7 +19,7 @@ import (
"github.com/mainflux/mainflux/lora"
"github.com/mainflux/mainflux/lora/api"
"github.com/mainflux/mainflux/lora/mqtt"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/pkg/messaging/nats"

kitprometheus "github.com/go-kit/kit/metrics/prometheus"
"github.com/mainflux/mainflux/lora/redis"
Expand Down
4 changes: 2 additions & 2 deletions cmd/mongodb-writer/main.go
Expand Up @@ -15,8 +15,8 @@ import (
kitprometheus "github.com/go-kit/kit/metrics/prometheus"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/transformers/senml"
"github.com/mainflux/mainflux/pkg/messaging/nats"
"github.com/mainflux/mainflux/pkg/transformers/senml"
"github.com/mainflux/mainflux/writers"
"github.com/mainflux/mainflux/writers/api"
"github.com/mainflux/mainflux/writers/mongodb"
Expand Down
8 changes: 4 additions & 4 deletions cmd/mqtt/main.go
Expand Up @@ -15,12 +15,12 @@ import (
"github.com/go-redis/redis"
"github.com/mainflux/mainflux"
mflog "github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging"
mqttpub "github.com/mainflux/mainflux/messaging/mqtt"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/mqtt"
"github.com/mainflux/mainflux/mqtt/auth"
mqttredis "github.com/mainflux/mainflux/mqtt/redis"
"github.com/mainflux/mainflux/pkg/auth"
"github.com/mainflux/mainflux/pkg/messaging"
mqttpub "github.com/mainflux/mainflux/pkg/messaging/mqtt"
"github.com/mainflux/mainflux/pkg/messaging/nats"
thingsapi "github.com/mainflux/mainflux/things/api/auth/grpc"
mp "github.com/mainflux/mproxy/pkg/mqtt"
"github.com/mainflux/mproxy/pkg/session"
Expand Down
2 changes: 1 addition & 1 deletion cmd/opcua/main.go
Expand Up @@ -16,12 +16,12 @@ import (
r "github.com/go-redis/redis"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/opcua"
"github.com/mainflux/mainflux/opcua/api"
"github.com/mainflux/mainflux/opcua/db"
"github.com/mainflux/mainflux/opcua/gopcua"
"github.com/mainflux/mainflux/opcua/redis"
"github.com/mainflux/mainflux/pkg/messaging/nats"

kitprometheus "github.com/go-kit/kit/metrics/prometheus"
stdprometheus "github.com/prometheus/client_golang/prometheus"
Expand Down
4 changes: 2 additions & 2 deletions cmd/postgres-writer/main.go
Expand Up @@ -15,8 +15,8 @@ import (
"github.com/jmoiron/sqlx"
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/transformers/senml"
"github.com/mainflux/mainflux/pkg/messaging/nats"
"github.com/mainflux/mainflux/pkg/transformers/senml"
"github.com/mainflux/mainflux/writers"
"github.com/mainflux/mainflux/writers/api"
"github.com/mainflux/mainflux/writers/postgres"
Expand Down
4 changes: 2 additions & 2 deletions cmd/provision/main.go
Expand Up @@ -11,11 +11,11 @@ import (
"syscall"

"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/errors"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/pkg/errors"
mfSDK "github.com/mainflux/mainflux/pkg/sdk/go"
"github.com/mainflux/mainflux/provision"
"github.com/mainflux/mainflux/provision/api"
mfSDK "github.com/mainflux/mainflux/sdk/go"
)

const (
Expand Down
4 changes: 2 additions & 2 deletions cmd/twins/main.go
Expand Up @@ -19,8 +19,8 @@ import (
"github.com/mainflux/mainflux"
authapi "github.com/mainflux/mainflux/authn/api/grpc"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging"
"github.com/mainflux/mainflux/messaging/nats"
"github.com/mainflux/mainflux/pkg/messaging"
"github.com/mainflux/mainflux/pkg/messaging/nats"
localusers "github.com/mainflux/mainflux/things/users"
"github.com/mainflux/mainflux/twins"
"github.com/mainflux/mainflux/twins/api"
Expand Down
2 changes: 1 addition & 1 deletion coap/adapter.go
Expand Up @@ -13,7 +13,7 @@ import (

"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging"
"github.com/mainflux/mainflux/pkg/messaging"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion coap/api/logging.go
Expand Up @@ -11,7 +11,7 @@ import (

"github.com/mainflux/mainflux/coap"
log "github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging"
"github.com/mainflux/mainflux/pkg/messaging"
)

var _ coap.Service = (*loggingMiddleware)(nil)
Expand Down
2 changes: 1 addition & 1 deletion coap/api/metrics.go
Expand Up @@ -10,7 +10,7 @@ import (

"github.com/go-kit/kit/metrics"
"github.com/mainflux/mainflux/coap"
"github.com/mainflux/mainflux/messaging"
"github.com/mainflux/mainflux/pkg/messaging"
)

var _ coap.Service = (*metricsMiddleware)(nil)
Expand Down
2 changes: 1 addition & 1 deletion coap/api/transport.go
Expand Up @@ -21,7 +21,7 @@ import (
"github.com/mainflux/mainflux"
"github.com/mainflux/mainflux/coap"
log "github.com/mainflux/mainflux/logger"
"github.com/mainflux/mainflux/messaging"
"github.com/mainflux/mainflux/pkg/messaging"
"github.com/prometheus/client_golang/prometheus/promhttp"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
Expand Down

0 comments on commit ea3a891

Please sign in to comment.