GO-4140 publish 2

.gitignore

@@ -18,3 +18,5 @@ tests/.cache/
 staging.yml
 build
 /core/anytype/config/nodes/custom.yml
+/.direnv/
+/.envrc

.mockery.yaml

@@ -225,3 +225,9 @@ packages:
   github.com/anyproto/anytype-heart/core/kanban:
     interfaces:
       Service:
+  github.com/anyproto/anytype-heart/core/core/inviteservice:
+    interfaces:
+      InviteService:
+  github.com/anyproto/anytype-heart/core/identity:
+    interfaces:
+      Service:

core/anytype/bootstrap.go

@@ -26,6 +26,7 @@ import (
 	"github.com/anyproto/any-sync/nodeconf/nodeconfstore"
 	"github.com/anyproto/any-sync/util/crypto"
 	"github.com/anyproto/any-sync/util/syncqueues"
+	"github.com/anyproto/anytype-publish-server/publishclient"
 	"go.uber.org/zap"
 
 	"github.com/anyproto/any-sync/nameservice/nameserviceclient"
@@ -80,6 +81,7 @@ import (
 	"github.com/anyproto/anytype-heart/core/payments"
 	paymentscache "github.com/anyproto/anytype-heart/core/payments/cache"
 	"github.com/anyproto/anytype-heart/core/peerstatus"
+	"github.com/anyproto/anytype-heart/core/publish"
 	"github.com/anyproto/anytype-heart/core/recordsbatcher"
 	"github.com/anyproto/anytype-heart/core/session"
 	"github.com/anyproto/anytype-heart/core/spaceview"
@@ -268,6 +270,8 @@ func Bootstrap(a *app.App, components ...app.Component) {
 		Register(reconciler.New()).
 		Register(fileobject.New(200*time.Millisecond, 2*time.Second)).
 		Register(inviteservice.New()).
+		Register(publish.New()).
+		Register(publishclient.New()).
 		Register(acl.New()).
 		Register(builtintemplate.New()).
 		Register(converter.NewLayoutConverter()).

core/anytype/config/config.go

@@ -12,6 +12,7 @@ import (
 	anystore "github.com/anyproto/any-store"
 	"github.com/anyproto/any-sync/app"
 	"github.com/anyproto/any-sync/net/streampool"
+	"github.com/anyproto/anytype-publish-server/publishclient"
 
 	//nolint:misspell
 	"github.com/anyproto/any-sync/commonspace/config"
@@ -455,3 +456,14 @@ func (c *Config) GetSpaceStorageMode() storage.SpaceStorageMode {
 func (c *Config) GetNetworkMode() pb.RpcAccountNetworkMode {
 	return c.NetworkMode
 }
+
+func (c *Config) GetPublishServer() publishclient.Config {
+	return publishclient.Config{
+		Addrs: []publishclient.PublishServerAddr{
+			{
+				PeerId: "12D3KooWEQPgbxGPvkny8kikS3zqfziM7JsQBnJHXHL9ByCcATs7",
+				Addrs:  []string{"yamux://anytype-publish-server-yamux-fb3a0765ead8fc08.elb.eu-central-2.amazonaws.com:443"},
+			},
+		},
+	}
+}

core/block/restriction/object.go

@@ -23,19 +23,22 @@ var (
 		model.Restrictions_TypeChange,
 		model.Restrictions_Template,
 		model.Restrictions_Duplicate,
+		model.Restrictions_Publish,
 	}
-	objRestrictEditAndDuplicate = ObjectRestrictions{
+	objRestrictEditPublishAndDuplicate = ObjectRestrictions{
 		model.Restrictions_Blocks,
 		model.Restrictions_LayoutChange,
 		model.Restrictions_TypeChange,
 		model.Restrictions_Template,
 		model.Restrictions_Duplicate,
+		model.Restrictions_Publish,
 	}
-	objRestrictEdit = ObjectRestrictions{
+	objRestrictEditAndPublish = ObjectRestrictions{
 		model.Restrictions_Blocks,
 		model.Restrictions_LayoutChange,
 		model.Restrictions_TypeChange,
 		model.Restrictions_Template,
+		model.Restrictions_Publish,
 	}
 	sysTypesRestrictions = ObjectRestrictions{
 		model.Restrictions_Blocks,
@@ -44,6 +47,7 @@ var (
 		model.Restrictions_Template,
 		model.Restrictions_Details,
 		model.Restrictions_Delete,
+		model.Restrictions_Publish,
 	}
 	sysRelationsRestrictions = ObjectRestrictions{
 		model.Restrictions_Blocks,
@@ -53,17 +57,18 @@ var (
 		model.Restrictions_Delete,
 		model.Restrictions_Relations,
 		model.Restrictions_Details,
+		model.Restrictions_Publish,
 	}
 
 	objectRestrictionsByLayout = map[model.ObjectTypeLayout]ObjectRestrictions{
 		model.ObjectType_basic:      {},
 		model.ObjectType_profile:    {},
 		model.ObjectType_todo:       {},
-		model.ObjectType_set:        objRestrictEdit,
-		model.ObjectType_collection: objRestrictEdit,
-		model.ObjectType_objectType: objRestrictEdit,
-		model.ObjectType_relation:   objRestrictEdit,
-		model.ObjectType_file:       objRestrictEditAndDuplicate,
+		model.ObjectType_set:        objRestrictEditAndPublish,
+		model.ObjectType_collection: objRestrictEditAndPublish,
+		model.ObjectType_objectType: objRestrictEditAndPublish,
+		model.ObjectType_relation:   objRestrictEditAndPublish,
+		model.ObjectType_file:       objRestrictEditPublishAndDuplicate,
 		model.ObjectType_dashboard: {
 			model.Restrictions_Details,
 			model.Restrictions_Relations,
@@ -80,14 +85,14 @@ var (
 		},
 
 		model.ObjectType_bookmark:       {},
-		model.ObjectType_relationOption: objRestrictEdit,
+		model.ObjectType_relationOption: objRestrictEditAndPublish,
 		model.ObjectType_relationOptionsList: {
 			model.Restrictions_Template,
 		},
 		model.ObjectType_participant: objRestrictAll,
-		model.ObjectType_chat:        objRestrictEditAndDuplicate,
-		model.ObjectType_chatDerived: objRestrictEditAndDuplicate,
-		model.ObjectType_tag:         objRestrictEdit,
+		model.ObjectType_chat:        objRestrictEditPublishAndDuplicate,
+		model.ObjectType_chatDerived: objRestrictEditPublishAndDuplicate,
+		model.ObjectType_tag:         objRestrictEditAndPublish,
 	}
 
 	objectRestrictionsBySBType = map[smartblock.SmartBlockType]ObjectRestrictions{
@@ -107,6 +112,7 @@ var (
 			model.Restrictions_TypeChange,
 			model.Restrictions_Template,
 			model.Restrictions_Duplicate,
+			model.Restrictions_Publish,
 		},
 		smartblock.SmartBlockTypeWorkspace: {
 			model.Restrictions_Blocks,
@@ -116,18 +122,20 @@ var (
 			model.Restrictions_TypeChange,
 			model.Restrictions_Template,
 			model.Restrictions_Duplicate,
+			model.Restrictions_Publish,
 		},
-		smartblock.SmartBlockTypeFileObject:        objRestrictEditAndDuplicate,
+		smartblock.SmartBlockTypeFileObject:        objRestrictEditPublishAndDuplicate,
 		smartblock.SmartBlockTypeArchive:           objRestrictAll,
 		smartblock.SmartBlockTypeBundledRelation:   objRestrictAll,
-		smartblock.SmartBlockTypeSubObject:         objRestrictEdit,
-		smartblock.SmartBlockTypeObjectType:        objRestrictEdit,
-		smartblock.SmartBlockTypeRelation:          objRestrictEdit,
+		smartblock.SmartBlockTypeSubObject:         objRestrictEditAndPublish,
+		smartblock.SmartBlockTypeObjectType:        objRestrictEditAndPublish,
+		smartblock.SmartBlockTypeRelation:          objRestrictEditAndPublish,
 		smartblock.SmartBlockTypeBundledObjectType: objRestrictAll,
 		smartblock.SmartBlockTypeBundledTemplate:   objRestrictAll,
 		smartblock.SmartBlockTypeTemplate: {
 			model.Restrictions_TypeChange,
 			model.Restrictions_Template,
+			model.Restrictions_Publish,
 		},
 		smartblock.SmartBlockTypeWidget: {
 			model.Restrictions_Relations,
@@ -137,15 +145,16 @@ var (
 			model.Restrictions_TypeChange,
 			model.Restrictions_Template,
 			model.Restrictions_Duplicate,
+			model.Restrictions_Publish,
 		},
 		smartblock.SmartBlockTypeMissingObject: objRestrictAll,
 		smartblock.SmartBlockTypeDate:          objRestrictAll,
 		smartblock.SmartBlockTypeAccountOld: {
 			model.Restrictions_Template,
 		},
 		smartblock.SmartBlockTypeParticipant:       objRestrictAll,
-		smartblock.SmartBlockTypeChatObject:        objRestrictEditAndDuplicate,
-		smartblock.SmartBlockTypeChatDerivedObject: objRestrictEditAndDuplicate,
+		smartblock.SmartBlockTypeChatObject:        objRestrictEditPublishAndDuplicate,
+		smartblock.SmartBlockTypeChatDerivedObject: objRestrictEditPublishAndDuplicate,
 	}
 )
 

core/block/restriction/object_test.go

@@ -21,9 +21,9 @@ func TestService_ObjectRestrictionsById(t *testing.T) {
 
 	t.Run("sets and collections should have edit restrictions", func(t *testing.T) {
 		collection := givenRestrictionHolder(coresb.SmartBlockTypePage, bundle.TypeKeyCollection)
-		assert.ErrorIs(t, rs.GetRestrictions(collection).Object.Check(objRestrictEdit...), ErrRestricted)
+		assert.ErrorIs(t, rs.GetRestrictions(collection).Object.Check(objRestrictEditAndPublish...), ErrRestricted)
 		set := givenRestrictionHolder(coresb.SmartBlockTypePage, bundle.TypeKeySet)
-		assert.ErrorIs(t, rs.GetRestrictions(set).Object.Check(objRestrictEdit...), ErrRestricted)
+		assert.ErrorIs(t, rs.GetRestrictions(set).Object.Check(objRestrictEditAndPublish...), ErrRestricted)
 	})
 
 	t.Run("plain pages should not have any restrictions", func(t *testing.T) {
@@ -95,7 +95,7 @@ func TestService_ObjectRestrictionsById(t *testing.T) {
 
 	t.Run("chat should have edit and duplication restrictions", func(t *testing.T) {
 		assert.ErrorIs(t, rs.GetRestrictions(givenRestrictionHolder(coresb.SmartBlockTypeChatObject, bundle.TypeKeyChat)).Object.Check(
-			objRestrictEditAndDuplicate...,
+			objRestrictEditPublishAndDuplicate...,
 		), ErrRestricted)
 	})
 }

core/date/date_test.go

@@ -43,7 +43,7 @@ func TestBuildDetailsFromTimestamp(t *testing.T) {
 			assert.Zero(t, tt.Hour())
 			assert.Zero(t, tt.Minute())
 			assert.Zero(t, tt.Second())
-			assert.Len(t, details.GetInt64List(bundle.RelationKeyRestrictions), 8)
+			assert.Len(t, details.GetInt64List(bundle.RelationKeyRestrictions), 9)
 		})
 	}
 }