feat: resource type dependencies

server/internal/database/instance_resource.go

@@ -71,6 +71,10 @@ func (r *InstanceResource) Dependencies() []resource.Identifier {
 	return dependencies
 }
 
+func (r *InstanceResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *InstanceResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	if err := r.updateConnectionInfo(ctx, rc); err != nil {
 		return resource.ErrNotFound

server/internal/database/lag_tracker_commit_ts_resource.go

@@ -62,6 +62,10 @@ func (r *LagTrackerCommitTimestampResource) Dependencies() []resource.Identifier
 	return deps
 }
 
+func (r *LagTrackerCommitTimestampResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *LagTrackerCommitTimestampResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	// Connect to receiver node
 	instance, err := GetPrimaryInstance(ctx, rc, r.ReceiverNode)

server/internal/database/node_resource.go

@@ -51,6 +51,10 @@ func (n *NodeResource) Dependencies() []resource.Identifier {
 	return dependencies
 }
 
+func (n *NodeResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (n *NodeResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	if err := n.Create(ctx, rc); err != nil {
 		return err

server/internal/database/operations/helpers_test.go

@@ -131,6 +131,10 @@ func (r *orchestratorResource) Dependencies() []resource.Identifier {
 	return nil
 }
 
+func (r *orchestratorResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *orchestratorResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	return nil
 }

server/internal/database/replication_slot_advance_from_cts_resource.go

@@ -51,6 +51,10 @@ func (r *ReplicationSlotAdvanceFromCTSResource) Dependencies() []resource.Identi
 	}
 }
 
+func (r *ReplicationSlotAdvanceFromCTSResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *ReplicationSlotAdvanceFromCTSResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	return nil
 }

server/internal/database/replication_slot_create_resource.go

@@ -47,6 +47,10 @@ func (r *ReplicationSlotCreateResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (r *ReplicationSlotCreateResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *ReplicationSlotCreateResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	instance, err := GetPrimaryInstance(ctx, rc, r.ProviderNode)
 	if err != nil {

server/internal/database/replication_slot_resource.go

@@ -52,6 +52,10 @@ func (r *ReplicationSlotResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (r *ReplicationSlotResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *ReplicationSlotResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	return nil
 }

server/internal/database/subscription_resource.go

@@ -61,6 +61,10 @@ func (s *SubscriptionResource) Dependencies() []resource.Identifier {
 	return deps
 }
 
+func (s *SubscriptionResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *SubscriptionResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	subscriber, err := GetPrimaryInstance(ctx, rc, s.SubscriberNode)
 	if err != nil {

server/internal/database/switchover_resource.go

@@ -52,6 +52,10 @@ func (s *SwitchoverResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (s *SwitchoverResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *SwitchoverResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	if !rc.State.HasResources(s.Dependencies()...) {
 		return resource.ErrNotFound

server/internal/database/sync_event_resource.go

@@ -52,6 +52,10 @@ func (r *SyncEventResource) Dependencies() []resource.Identifier {
 	return deps
 }
 
+func (r *SyncEventResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 // Confirm synchronization by sending sync_event from provider and waiting for it on subscriber
 func (r *SyncEventResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	// Get provider instance

server/internal/database/wait_for_sync_event_resource.go

@@ -50,6 +50,10 @@ func (r *WaitForSyncEventResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (r *WaitForSyncEventResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 // Confirm synchronization by sending sync_event from provider and waiting for it on subscriber
 func (r *WaitForSyncEventResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	// Get subscriber instance

server/internal/filesystem/dir_resource.go

@@ -64,6 +64,10 @@ func (d *DirResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (d *DirResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (d *DirResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	fs, err := do.Invoke[afero.Fs](rc.Injector)
 	if err != nil {

server/internal/monitor/instance_monitor_resource.go

@@ -49,6 +49,10 @@ func (m *InstanceMonitorResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (m *InstanceMonitorResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (m *InstanceMonitorResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	service, err := do.Invoke[*Service](rc.Injector)
 	if err != nil {

server/internal/monitor/service_instance_monitor_resource.go

@@ -50,6 +50,10 @@ func (m *ServiceInstanceMonitorResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (m *ServiceInstanceMonitorResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (m *ServiceInstanceMonitorResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	service, err := do.Invoke[*Service](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/check_will_restart.go

@@ -55,6 +55,10 @@ func (c *CheckWillRestart) Dependencies() []resource.Identifier {
 	}
 }
 
+func (c *CheckWillRestart) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (c *CheckWillRestart) Refresh(ctx context.Context, rc *resource.Context) error {
 	if !rc.State.HasResources(c.Dependencies()...) {
 		return resource.ErrNotFound

server/internal/orchestrator/swarm/etcd_creds.go

@@ -71,6 +71,10 @@ func (c *EtcdCreds) Dependencies() []resource.Identifier {
 	}
 }
 
+func (c *EtcdCreds) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (c *EtcdCreds) Refresh(ctx context.Context, rc *resource.Context) error {
 	fs, err := do.Invoke[afero.Fs](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/mcp_config_resource.go

@@ -72,6 +72,10 @@ func (r *MCPConfigResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (r *MCPConfigResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *MCPConfigResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	fs, err := do.Invoke[afero.Fs](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/network.go

@@ -63,6 +63,10 @@ func (n *Network) Dependencies() []resource.Identifier {
 	return nil
 }
 
+func (n *Network) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (n *Network) Validate() error {
 	var errs []error
 	if n.Scope == "" {

server/internal/orchestrator/swarm/patroni_cluster.go

@@ -47,6 +47,10 @@ func (p *PatroniCluster) Dependencies() []resource.Identifier {
 	return nil
 }
 
+func (p *PatroniCluster) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (p *PatroniCluster) Refresh(ctx context.Context, rc *resource.Context) error {
 	return nil
 }

server/internal/orchestrator/swarm/patroni_config.go

@@ -80,6 +80,10 @@ func (c *PatroniConfig) Dependencies() []resource.Identifier {
 	return deps
 }
 
+func (r *PatroniConfig) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (c *PatroniConfig) Refresh(ctx context.Context, rc *resource.Context) error {
 	fs, err := do.Invoke[afero.Fs](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/patroni_member.go

@@ -51,6 +51,10 @@ func (p *PatroniMember) Dependencies() []resource.Identifier {
 	}
 }
 
+func (p *PatroniMember) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (p *PatroniMember) Refresh(ctx context.Context, rc *resource.Context) error {
 	return nil
 }

server/internal/orchestrator/swarm/pgbackrest_config.go

@@ -71,6 +71,10 @@ func (c *PgBackRestConfig) Dependencies() []resource.Identifier {
 	}
 }
 
+func (c *PgBackRestConfig) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (c *PgBackRestConfig) Refresh(ctx context.Context, rc *resource.Context) error {
 	fs, err := do.Invoke[afero.Fs](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/pgbackrest_restore.go

@@ -68,6 +68,10 @@ func (p *PgBackRestRestore) Dependencies() []resource.Identifier {
 	}
 }
 
+func (p *PgBackRestRestore) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (p *PgBackRestRestore) Refresh(ctx context.Context, rc *resource.Context) error {
 	return nil
 }

server/internal/orchestrator/swarm/pgbackrest_stanza.go

@@ -49,6 +49,10 @@ func (p *PgBackRestStanza) Dependencies() []resource.Identifier {
 	}
 }
 
+func (p *PgBackRestStanza) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (p *PgBackRestStanza) Refresh(ctx context.Context, rc *resource.Context) error {
 	client, err := do.Invoke[*docker.Docker](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/postgres_certs.go

@@ -71,6 +71,10 @@ func (c *PostgresCerts) Dependencies() []resource.Identifier {
 	}
 }
 
+func (c *PostgresCerts) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (c *PostgresCerts) Refresh(ctx context.Context, rc *resource.Context) error {
 	fs, err := do.Invoke[afero.Fs](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/postgres_service.go

@@ -59,6 +59,10 @@ func (s *PostgresService) Dependencies() []resource.Identifier {
 	}
 }
 
+func (s *PostgresService) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *PostgresService) Refresh(ctx context.Context, rc *resource.Context) error {
 	client, err := do.Invoke[*docker.Docker](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/postgres_service_spec.go

@@ -65,6 +65,10 @@ func (s *PostgresServiceSpecResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (s *PostgresServiceSpecResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *PostgresServiceSpecResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	network, err := resource.FromContext[*Network](rc, NetworkResourceIdentifier(s.DatabaseNetworkName))
 	if err != nil {

server/internal/orchestrator/swarm/scale_service.go

@@ -46,6 +46,10 @@ func (s *ScaleService) Dependencies() []resource.Identifier {
 	return append([]resource.Identifier{PostgresServiceResourceIdentifier(s.InstanceID)}, s.Deps...)
 }
 
+func (s *ScaleService) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *ScaleService) Refresh(ctx context.Context, rc *resource.Context) error {
 	return resource.ErrNotFound
 }

server/internal/orchestrator/swarm/service_instance.go

@@ -66,6 +66,10 @@ func (s *ServiceInstanceResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (s *ServiceInstanceResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *ServiceInstanceResource) Refresh(ctx context.Context, rc *resource.Context) error {
 	client, err := do.Invoke[*docker.Docker](rc.Injector)
 	if err != nil {

server/internal/orchestrator/swarm/service_instance_spec.go

@@ -68,6 +68,10 @@ func (s *ServiceInstanceSpecResource) Dependencies() []resource.Identifier {
 	}
 }
 
+func (s *ServiceInstanceSpecResource) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *ServiceInstanceSpecResource) populateCredentials(rc *resource.Context) error {
 	userRole, err := resource.FromContext[*ServiceUserRole](rc, ServiceUserRoleIdentifier(s.ServiceSpec.ServiceID))
 	if err != nil {

server/internal/orchestrator/swarm/service_user_role.go

@@ -81,6 +81,10 @@ func (r *ServiceUserRole) Dependencies() []resource.Identifier {
 	return nil
 }
 
+func (r *ServiceUserRole) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (r *ServiceUserRole) Refresh(ctx context.Context, rc *resource.Context) error {
 	// If username or password is empty, the resource state is from before we
 	// added credential management. Return ErrNotFound to trigger recreation.

server/internal/orchestrator/swarm/switchover.go

@@ -48,6 +48,10 @@ func (s *Switchover) Dependencies() []resource.Identifier {
 	}
 }
 
+func (s *Switchover) TypeDependencies() []resource.Type {
+	return nil
+}
+
 func (s *Switchover) Refresh(ctx context.Context, rc *resource.Context) error {
 	if !rc.State.HasResources(s.Dependencies()...) {
 		return resource.ErrNotFound