getTransformedTableNameFromSchema extracts the table name from a transformed schema
(transformedSchemaBytes []byte)
| 844 | |
| 845 | // getTransformedTableNameFromSchema extracts the table name from a transformed schema |
| 846 | func getTransformedTableNameFromSchema(transformedSchemaBytes []byte) (string, error) { |
| 847 | finalSchema, err := plugin.NewSchemaFromBytes(transformedSchemaBytes) |
| 848 | if err != nil { |
| 849 | return "", errors.Join(errors.New("failed to create schema from bytes"), err) |
| 850 | } |
| 851 | |
| 852 | tableName, ok := finalSchema.Metadata().GetValue(schema.MetadataTableName) |
| 853 | if !ok { |
| 854 | return "", errors.New("table name not found in transformed schema metadata") |
| 855 | } |
| 856 | |
| 857 | return tableName, nil |
| 858 | } |