globaloperationmutator

var GQLGlobalOperationMutatorType = graphql.NewObject(graphql.ObjectConfig{
	Name:        "GlobalOperationMutator",
	Description: "`GlobalOperationMutator`",
	Fields: graphql.Fields{
		"propose": Propose,
	},
})

var Propose = &graphql.Field{
	Name:        "Propose",
	Description: "`Propose`",
	Type:        kind.GQLProposalResponseType,
	Args: graphql.FieldConfigArgument{
		"proposal": &graphql.ArgumentConfig{
			Description: "Proposal",
			Type:        graphql.NewNonNull(kind.GQLProposalInputType),
		},
	},

	Resolve: func(p graphql.ResolveParams) (interface{}, error) {
		ctx, ok := p.Source.(*context.GlobalOperationContext)
		if !ok {
			return nil, nil
		}

		namespace := ctx.GlobalOperation.Namespace()
		proposalMap := p.Args["proposal"].(map[string]interface{})
		if !utility.HasGlobalCRUDPermission(ctx.AccessControl) {
			return nil, gqlerrors.NewFormattedError(x.ErrGlobalCRUDPermissionRequired.Error())
		}

		meta := []byte("")
		if v, found := proposalMap["meta"]; found {
			v2, err2 := base64.StdEncoding.DecodeString(v.(string))
			if err2 != nil {
				return nil, gqlerrors.NewFormattedError(x.ErrDecodingError.Error())
			}
			meta = v2
		}

		proposal := pb.NewProposal()
		proposal.Meta = meta
		for _, st := range proposalMap["transactions"].([]interface{}) {
			stm := st.(map[string]interface{})
			payload := stm["payload"].(string)
			familyName := stm["familyName"].(string)
			familyVersion := stm["familyVersion"].(string)

			if payload == "" {
				return nil, gqlerrors.NewFormattedError(x.ErrPayloadCanNotBeEmpty.Error())
			}
			if familyName == "" {
				return nil, gqlerrors.NewFormattedError(x.ErrFamilyNameCanNotBeEmpty.Error())
			}
			if familyVersion == "" {
				return nil, gqlerrors.NewFormattedError(x.ErrFamilyVersionCanNotBeEmpty.Error())
			}

			payloadBytes, err := base64.StdEncoding.DecodeString(payload)
			if err != nil {
				return nil, gqlerrors.NewFormattedError(x.ErrDecodingError.Error())
			}

			proposal.AddTransaction(namespace, familyName, familyVersion, payloadBytes)
		}

		o, err := ctx.GlobalOperation.Propose(proposal)
		if err != nil {
			return nil, gqlerrors.NewFormattedError(err.Error())
		}
		return o, nil
	},
}