updateAzureContainer.go

func updateAzureContainer(resourceGroupName, containerGroupName string, webhookData WebhookData) error {
	containerGroupsClient, err := getContainerGroupsClient()
	if err != nil {
		return fmt.Errorf("cannot get container groups client: %v", err)
	}

	containerGroup, err := containerGroupsClient.Get(resourceGroupName, containerGroupName)
	if err != nil {
		return fmt.Errorf("cannot get container group: %v", err)
	}

	containers := *containerGroup.Containers
	for index, container := range containers {
		image := *container.Image
		newVersion := fmt.Sprintf("%s/%s:%s",
			webhookData.Repository.Namespace,
			webhookData.Repository.Name,
			webhookData.PushData.Tag)

		if image == fmt.Sprintf("%s/%s", webhookData.Repository.Namespace, webhookData.Repository.Name) {
			updatedContainer := (*containerGroup.Containers)[index]
			*updatedContainer.Image = newVersion

			_, err := containerGroupsClient.CreateOrUpdate(resourceGroupName, containerGroupName, containerGroup)
			if err != nil {
				return fmt.Errorf("cannot update container: %v", err)
			}
			fmt.Printf("updated container image to new version: %s", newVersion)
		}
	}
	return nil
}