@@ -23,18 +23,18 @@ import (
2323 "github.com/dave/jennifer/jen"
2424)
2525
26- // GenerateTranslationLayers generates translation layers for all mappings
27- func GenerateTranslationLayers (resourceName string , mappings []MappingWithConfig , translationOutDir string ) error {
26+ // GenerateServiceLayers generates service layers for all mappings
27+ func GenerateServiceLayers (resourceName string , mappings []MappingWithConfig , translationOutDir string ) error {
2828 for _ , mapping := range mappings {
2929 versionSuffix := mapping .Version
30- if err := generateTranslationLayerWithVersion (resourceName , versionSuffix , mapping .OpenAPIConfig .Package , translationOutDir ); err != nil {
31- return fmt .Errorf ("failed to generate translation layer for version %s: %w" , versionSuffix , err )
30+ if err := generateServiceLayerWithVersion (resourceName , versionSuffix , mapping .OpenAPIConfig .Package , translationOutDir ); err != nil {
31+ return fmt .Errorf ("failed to generate service layer for version %s: %w" , versionSuffix , err )
3232 }
3333 }
3434 return nil
3535}
3636
37- func generateTranslationLayerWithVersion (resourceName , versionSuffix , sdkPackage , translationOutDir string ) error {
37+ func generateServiceLayerWithVersion (resourceName , versionSuffix , sdkPackage , translationOutDir string ) error {
3838 packageName := strings .ToLower (resourceName ) + versionSuffix
3939 translationDir := filepath .Join (translationOutDir , packageName )
4040
@@ -121,15 +121,15 @@ func generateServiceFileWithVersion(dir, resourceName, packageName, sdkPackage s
121121 )
122122
123123 // Service implementation struct
124- f .Type ().Id ("Atlas" + resourceName + "ServiceImpl" ).Struct (
124+ f .Type ().Id ("Atlas" + resourceName + "ServiceImpl" ).Struct (
125125 jen .Id (strings .ToLower (resourceName )+ "API" ).Qual (sdkPackage , atlasAPI ),
126126 )
127127
128128 // Constructor
129- f .Func ().Id ("NewAtlas" + resourceName + "Service" ).Params (
129+ f .Func ().Id ("NewAtlas" + resourceName + "Service" ).Params (
130130 jen .Id ("api" ).Qual (sdkPackage , atlasAPI ),
131- ).Id ("Atlas" + resourceName + "Service" ).Block (
132- jen .Return (jen .Op ("&" ).Id ("Atlas" + resourceName + "ServiceImpl" ).Values (jen.Dict {
131+ ).Id ("Atlas" + resourceName + "Service" ).Block (
132+ jen .Return (jen .Op ("&" ).Id ("Atlas" + resourceName + "ServiceImpl" ).Values (jen.Dict {
133133 jen .Id (strings .ToLower (resourceName ) + "API" ): jen .Id ("api" ),
134134 })),
135135 )
@@ -164,7 +164,7 @@ func generateServiceFileWithVersion(dir, resourceName, packageName, sdkPackage s
164164 jen .Id ("ctx" ).Qual ("context" , "Context" ),
165165 jen .Id ("orgID" ).String (),
166166 jen .Id ("resourceID" ).String (),
167- jen .Id ("a" + strings .ToLower (resourceName )).Op ("*" ).Id ("Atlas" + resourceName ),
167+ jen .Id ("a" + strings .ToLower (resourceName )).Op ("*" ).Id ("Atlas" + resourceName ),
168168 },
169169 ret : []jen.Code {jen .Op ("*" ).Id ("Atlas" + resourceName ), jen .Error ()},
170170 },
@@ -193,26 +193,26 @@ func generateServiceFileWithVersion(dir, resourceName, packageName, sdkPackage s
193193// GetAtlasAPIForCRD maps CRD kinds to their corresponding Atlas API types
194194func GetAtlasAPIForCRD (crdKind string ) (string , error ) {
195195 apiMapping := map [string ]string {
196- "Project" : "ProjectsApi" ,
197- "Group" : "ProjectsApi" , // Groups are managed by ProjectsApi
198- "Organization" : "OrganizationsApi" ,
199- "DatabaseUser" : "DatabaseUsersApi" ,
200- "Deployment" : "ClustersApi" ,
201- "StreamInstance" : "StreamsApi" ,
202- "PrivateEndpoint" : "PrivateEndpointServicesApi" ,
203- "NetworkPeering" : "NetworkPeeringApi" ,
196+ "Project" : "ProjectsApi" ,
197+ "Group" : "ProjectsApi" , // Groups are managed by ProjectsApi
198+ "Organization" : "OrganizationsApi" ,
199+ "DatabaseUser" : "DatabaseUsersApi" ,
200+ "Deployment" : "ClustersApi" ,
201+ "StreamInstance" : "StreamsApi" ,
202+ "PrivateEndpoint" : "PrivateEndpointServicesApi" ,
203+ "NetworkPeering" : "NetworkPeeringApi" ,
204204 "NetworkPeeringConnection" : "NetworkPeeringApi" ,
205- "NetworkContainer" : "NetworkPeeringApi" ,
206- "IPAccessList" : "ProjectIPAccessListApi" ,
207- "CustomRole" : "CustomDatabaseRolesApi" ,
208- "BackupCompliancePolicy" : "CompliancePoliciesApi" ,
209- "DataFederation" : "DataFederationApi" ,
210- "ThirdPartyIntegrations" : "ThirdPartyIntegrationsApi" ,
211- "FederatedAuth" : "FederatedAuthenticationApi" ,
212- "SearchIndexConfig" : "AtlasSearchApi" ,
213- "OrgSettings" : "OrganizationsApi" ,
214- "StreamConnection" : "StreamsApi" ,
215- "Team" : "TeamsApi" ,
205+ "NetworkContainer" : "NetworkPeeringApi" ,
206+ "IPAccessList" : "ProjectIPAccessListApi" ,
207+ "CustomRole" : "CustomDatabaseRolesApi" ,
208+ "BackupCompliancePolicy" : "CompliancePoliciesApi" ,
209+ "DataFederation" : "DataFederationApi" ,
210+ "ThirdPartyIntegrations" : "ThirdPartyIntegrationsApi" ,
211+ "FederatedAuth" : "FederatedAuthenticationApi" ,
212+ "SearchIndexConfig" : "AtlasSearchApi" ,
213+ "OrgSettings" : "OrganizationsApi" ,
214+ "StreamConnection" : "StreamsApi" ,
215+ "Team" : "TeamsApi" ,
216216 }
217217
218218 if api , exists := apiMapping [crdKind ]; exists {
@@ -236,4 +236,4 @@ func AddLicenseHeader(f *jen.File) {
236236 f .HeaderComment ("WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied." )
237237 f .HeaderComment ("See the License for the specific language governing permissions and" )
238238 f .HeaderComment ("limitations under the License." )
239- }
239+ }
0 commit comments