+ ledger account ownerRef

api/ledger/internal/service/ledger/accounts.go

@@ -76,6 +76,15 @@ func (s *Service) createAccountResponder(_ context.Context, req *ledgerv1.Create
 
 		describable := describableFromProto(req.GetDescribable())
 
+		var ownerRef *primitive.ObjectID
+		if req.GetOwnerRef() != "" {
+			ownerObjID, err := parseObjectID(req.GetOwnerRef())
+			if err != nil {
+				return nil, merrors.InvalidArgument(req.GetOwnerRef(), "owner_ref")
+			}
+			ownerRef = &ownerObjID
+		}
+
 		account := &model.Account{
 			AccountCode:   accountCode,
 			Currency:      currency,
@@ -84,6 +93,7 @@ func (s *Service) createAccountResponder(_ context.Context, req *ledgerv1.Create
 			AllowNegative: req.GetAllowNegative(),
 			IsSettlement:  req.GetIsSettlement(),
 			Metadata:      metadata,
+			OwnerRef:      ownerRef,
 		}
 		if describable != nil {
 			account.Describable = *describable
@@ -209,9 +219,15 @@ func toProtoAccount(account *model.Account) *ledgerv1.LedgerAccount {
 		metadata = nil
 	}
 
+	var ownerRef string
+	if account.OwnerRef != nil && !account.OwnerRef.IsZero() {
+		ownerRef = account.OwnerRef.Hex()
+	}
+
 	return &ledgerv1.LedgerAccount{
 		LedgerAccountRef: accountRef,
 		OrganizationRef:  organizationRef,
+		OwnerRef:         ownerRef,
 		AccountCode:      account.AccountCode,
 		AccountType:      modelAccountTypeToProto(account.AccountType),
 		Currency:         account.Currency,

api/ledger/internal/service/ledger/connector.go

@@ -89,6 +89,7 @@ func (c *connectorAdapter) OpenAccount(ctx context.Context, req *connectorv1.Ope
 		IsSettlement:    reader.Bool("is_settlement"),
 		Metadata:        metadata,
 		Describable:     describable,
+		OwnerRef:        req.GetOwnerRef(),
 	})
 	if err != nil {
 		return &connectorv1.OpenAccountResponse{Error: connectorError(mapErrorCode(err), err.Error(), nil, "")}, nil