deserializers.go 29 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172
  1. // Code generated by smithy-go-codegen DO NOT EDIT.
  2. package sso
  3. import (
  4. "bytes"
  5. "context"
  6. "encoding/json"
  7. "fmt"
  8. "github.com/aws/aws-sdk-go-v2/aws/protocol/restjson"
  9. "github.com/aws/aws-sdk-go-v2/service/sso/types"
  10. smithy "github.com/aws/smithy-go"
  11. smithyio "github.com/aws/smithy-go/io"
  12. "github.com/aws/smithy-go/middleware"
  13. "github.com/aws/smithy-go/ptr"
  14. "github.com/aws/smithy-go/tracing"
  15. smithyhttp "github.com/aws/smithy-go/transport/http"
  16. "io"
  17. "io/ioutil"
  18. "strings"
  19. )
  20. type awsRestjson1_deserializeOpGetRoleCredentials struct {
  21. }
  22. func (*awsRestjson1_deserializeOpGetRoleCredentials) ID() string {
  23. return "OperationDeserializer"
  24. }
  25. func (m *awsRestjson1_deserializeOpGetRoleCredentials) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
  26. out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
  27. ) {
  28. out, metadata, err = next.HandleDeserialize(ctx, in)
  29. if err != nil {
  30. return out, metadata, err
  31. }
  32. _, span := tracing.StartSpan(ctx, "OperationDeserializer")
  33. endTimer := startMetricTimer(ctx, "client.call.deserialization_duration")
  34. defer endTimer()
  35. defer span.End()
  36. response, ok := out.RawResponse.(*smithyhttp.Response)
  37. if !ok {
  38. return out, metadata, &smithy.DeserializationError{Err: fmt.Errorf("unknown transport type %T", out.RawResponse)}
  39. }
  40. if response.StatusCode < 200 || response.StatusCode >= 300 {
  41. return out, metadata, awsRestjson1_deserializeOpErrorGetRoleCredentials(response, &metadata)
  42. }
  43. output := &GetRoleCredentialsOutput{}
  44. out.Result = output
  45. var buff [1024]byte
  46. ringBuffer := smithyio.NewRingBuffer(buff[:])
  47. body := io.TeeReader(response.Body, ringBuffer)
  48. decoder := json.NewDecoder(body)
  49. decoder.UseNumber()
  50. var shape interface{}
  51. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  52. var snapshot bytes.Buffer
  53. io.Copy(&snapshot, ringBuffer)
  54. err = &smithy.DeserializationError{
  55. Err: fmt.Errorf("failed to decode response body, %w", err),
  56. Snapshot: snapshot.Bytes(),
  57. }
  58. return out, metadata, err
  59. }
  60. err = awsRestjson1_deserializeOpDocumentGetRoleCredentialsOutput(&output, shape)
  61. if err != nil {
  62. var snapshot bytes.Buffer
  63. io.Copy(&snapshot, ringBuffer)
  64. return out, metadata, &smithy.DeserializationError{
  65. Err: fmt.Errorf("failed to decode response body with invalid JSON, %w", err),
  66. Snapshot: snapshot.Bytes(),
  67. }
  68. }
  69. span.End()
  70. return out, metadata, err
  71. }
  72. func awsRestjson1_deserializeOpErrorGetRoleCredentials(response *smithyhttp.Response, metadata *middleware.Metadata) error {
  73. var errorBuffer bytes.Buffer
  74. if _, err := io.Copy(&errorBuffer, response.Body); err != nil {
  75. return &smithy.DeserializationError{Err: fmt.Errorf("failed to copy error response body, %w", err)}
  76. }
  77. errorBody := bytes.NewReader(errorBuffer.Bytes())
  78. errorCode := "UnknownError"
  79. errorMessage := errorCode
  80. headerCode := response.Header.Get("X-Amzn-ErrorType")
  81. if len(headerCode) != 0 {
  82. errorCode = restjson.SanitizeErrorCode(headerCode)
  83. }
  84. var buff [1024]byte
  85. ringBuffer := smithyio.NewRingBuffer(buff[:])
  86. body := io.TeeReader(errorBody, ringBuffer)
  87. decoder := json.NewDecoder(body)
  88. decoder.UseNumber()
  89. jsonCode, message, err := restjson.GetErrorInfo(decoder)
  90. if err != nil {
  91. var snapshot bytes.Buffer
  92. io.Copy(&snapshot, ringBuffer)
  93. err = &smithy.DeserializationError{
  94. Err: fmt.Errorf("failed to decode response body, %w", err),
  95. Snapshot: snapshot.Bytes(),
  96. }
  97. return err
  98. }
  99. errorBody.Seek(0, io.SeekStart)
  100. if len(headerCode) == 0 && len(jsonCode) != 0 {
  101. errorCode = restjson.SanitizeErrorCode(jsonCode)
  102. }
  103. if len(message) != 0 {
  104. errorMessage = message
  105. }
  106. switch {
  107. case strings.EqualFold("InvalidRequestException", errorCode):
  108. return awsRestjson1_deserializeErrorInvalidRequestException(response, errorBody)
  109. case strings.EqualFold("ResourceNotFoundException", errorCode):
  110. return awsRestjson1_deserializeErrorResourceNotFoundException(response, errorBody)
  111. case strings.EqualFold("TooManyRequestsException", errorCode):
  112. return awsRestjson1_deserializeErrorTooManyRequestsException(response, errorBody)
  113. case strings.EqualFold("UnauthorizedException", errorCode):
  114. return awsRestjson1_deserializeErrorUnauthorizedException(response, errorBody)
  115. default:
  116. genericError := &smithy.GenericAPIError{
  117. Code: errorCode,
  118. Message: errorMessage,
  119. }
  120. return genericError
  121. }
  122. }
  123. func awsRestjson1_deserializeOpDocumentGetRoleCredentialsOutput(v **GetRoleCredentialsOutput, value interface{}) error {
  124. if v == nil {
  125. return fmt.Errorf("unexpected nil of type %T", v)
  126. }
  127. if value == nil {
  128. return nil
  129. }
  130. shape, ok := value.(map[string]interface{})
  131. if !ok {
  132. return fmt.Errorf("unexpected JSON type %v", value)
  133. }
  134. var sv *GetRoleCredentialsOutput
  135. if *v == nil {
  136. sv = &GetRoleCredentialsOutput{}
  137. } else {
  138. sv = *v
  139. }
  140. for key, value := range shape {
  141. switch key {
  142. case "roleCredentials":
  143. if err := awsRestjson1_deserializeDocumentRoleCredentials(&sv.RoleCredentials, value); err != nil {
  144. return err
  145. }
  146. default:
  147. _, _ = key, value
  148. }
  149. }
  150. *v = sv
  151. return nil
  152. }
  153. type awsRestjson1_deserializeOpListAccountRoles struct {
  154. }
  155. func (*awsRestjson1_deserializeOpListAccountRoles) ID() string {
  156. return "OperationDeserializer"
  157. }
  158. func (m *awsRestjson1_deserializeOpListAccountRoles) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
  159. out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
  160. ) {
  161. out, metadata, err = next.HandleDeserialize(ctx, in)
  162. if err != nil {
  163. return out, metadata, err
  164. }
  165. _, span := tracing.StartSpan(ctx, "OperationDeserializer")
  166. endTimer := startMetricTimer(ctx, "client.call.deserialization_duration")
  167. defer endTimer()
  168. defer span.End()
  169. response, ok := out.RawResponse.(*smithyhttp.Response)
  170. if !ok {
  171. return out, metadata, &smithy.DeserializationError{Err: fmt.Errorf("unknown transport type %T", out.RawResponse)}
  172. }
  173. if response.StatusCode < 200 || response.StatusCode >= 300 {
  174. return out, metadata, awsRestjson1_deserializeOpErrorListAccountRoles(response, &metadata)
  175. }
  176. output := &ListAccountRolesOutput{}
  177. out.Result = output
  178. var buff [1024]byte
  179. ringBuffer := smithyio.NewRingBuffer(buff[:])
  180. body := io.TeeReader(response.Body, ringBuffer)
  181. decoder := json.NewDecoder(body)
  182. decoder.UseNumber()
  183. var shape interface{}
  184. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  185. var snapshot bytes.Buffer
  186. io.Copy(&snapshot, ringBuffer)
  187. err = &smithy.DeserializationError{
  188. Err: fmt.Errorf("failed to decode response body, %w", err),
  189. Snapshot: snapshot.Bytes(),
  190. }
  191. return out, metadata, err
  192. }
  193. err = awsRestjson1_deserializeOpDocumentListAccountRolesOutput(&output, shape)
  194. if err != nil {
  195. var snapshot bytes.Buffer
  196. io.Copy(&snapshot, ringBuffer)
  197. return out, metadata, &smithy.DeserializationError{
  198. Err: fmt.Errorf("failed to decode response body with invalid JSON, %w", err),
  199. Snapshot: snapshot.Bytes(),
  200. }
  201. }
  202. span.End()
  203. return out, metadata, err
  204. }
  205. func awsRestjson1_deserializeOpErrorListAccountRoles(response *smithyhttp.Response, metadata *middleware.Metadata) error {
  206. var errorBuffer bytes.Buffer
  207. if _, err := io.Copy(&errorBuffer, response.Body); err != nil {
  208. return &smithy.DeserializationError{Err: fmt.Errorf("failed to copy error response body, %w", err)}
  209. }
  210. errorBody := bytes.NewReader(errorBuffer.Bytes())
  211. errorCode := "UnknownError"
  212. errorMessage := errorCode
  213. headerCode := response.Header.Get("X-Amzn-ErrorType")
  214. if len(headerCode) != 0 {
  215. errorCode = restjson.SanitizeErrorCode(headerCode)
  216. }
  217. var buff [1024]byte
  218. ringBuffer := smithyio.NewRingBuffer(buff[:])
  219. body := io.TeeReader(errorBody, ringBuffer)
  220. decoder := json.NewDecoder(body)
  221. decoder.UseNumber()
  222. jsonCode, message, err := restjson.GetErrorInfo(decoder)
  223. if err != nil {
  224. var snapshot bytes.Buffer
  225. io.Copy(&snapshot, ringBuffer)
  226. err = &smithy.DeserializationError{
  227. Err: fmt.Errorf("failed to decode response body, %w", err),
  228. Snapshot: snapshot.Bytes(),
  229. }
  230. return err
  231. }
  232. errorBody.Seek(0, io.SeekStart)
  233. if len(headerCode) == 0 && len(jsonCode) != 0 {
  234. errorCode = restjson.SanitizeErrorCode(jsonCode)
  235. }
  236. if len(message) != 0 {
  237. errorMessage = message
  238. }
  239. switch {
  240. case strings.EqualFold("InvalidRequestException", errorCode):
  241. return awsRestjson1_deserializeErrorInvalidRequestException(response, errorBody)
  242. case strings.EqualFold("ResourceNotFoundException", errorCode):
  243. return awsRestjson1_deserializeErrorResourceNotFoundException(response, errorBody)
  244. case strings.EqualFold("TooManyRequestsException", errorCode):
  245. return awsRestjson1_deserializeErrorTooManyRequestsException(response, errorBody)
  246. case strings.EqualFold("UnauthorizedException", errorCode):
  247. return awsRestjson1_deserializeErrorUnauthorizedException(response, errorBody)
  248. default:
  249. genericError := &smithy.GenericAPIError{
  250. Code: errorCode,
  251. Message: errorMessage,
  252. }
  253. return genericError
  254. }
  255. }
  256. func awsRestjson1_deserializeOpDocumentListAccountRolesOutput(v **ListAccountRolesOutput, value interface{}) error {
  257. if v == nil {
  258. return fmt.Errorf("unexpected nil of type %T", v)
  259. }
  260. if value == nil {
  261. return nil
  262. }
  263. shape, ok := value.(map[string]interface{})
  264. if !ok {
  265. return fmt.Errorf("unexpected JSON type %v", value)
  266. }
  267. var sv *ListAccountRolesOutput
  268. if *v == nil {
  269. sv = &ListAccountRolesOutput{}
  270. } else {
  271. sv = *v
  272. }
  273. for key, value := range shape {
  274. switch key {
  275. case "nextToken":
  276. if value != nil {
  277. jtv, ok := value.(string)
  278. if !ok {
  279. return fmt.Errorf("expected NextTokenType to be of type string, got %T instead", value)
  280. }
  281. sv.NextToken = ptr.String(jtv)
  282. }
  283. case "roleList":
  284. if err := awsRestjson1_deserializeDocumentRoleListType(&sv.RoleList, value); err != nil {
  285. return err
  286. }
  287. default:
  288. _, _ = key, value
  289. }
  290. }
  291. *v = sv
  292. return nil
  293. }
  294. type awsRestjson1_deserializeOpListAccounts struct {
  295. }
  296. func (*awsRestjson1_deserializeOpListAccounts) ID() string {
  297. return "OperationDeserializer"
  298. }
  299. func (m *awsRestjson1_deserializeOpListAccounts) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
  300. out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
  301. ) {
  302. out, metadata, err = next.HandleDeserialize(ctx, in)
  303. if err != nil {
  304. return out, metadata, err
  305. }
  306. _, span := tracing.StartSpan(ctx, "OperationDeserializer")
  307. endTimer := startMetricTimer(ctx, "client.call.deserialization_duration")
  308. defer endTimer()
  309. defer span.End()
  310. response, ok := out.RawResponse.(*smithyhttp.Response)
  311. if !ok {
  312. return out, metadata, &smithy.DeserializationError{Err: fmt.Errorf("unknown transport type %T", out.RawResponse)}
  313. }
  314. if response.StatusCode < 200 || response.StatusCode >= 300 {
  315. return out, metadata, awsRestjson1_deserializeOpErrorListAccounts(response, &metadata)
  316. }
  317. output := &ListAccountsOutput{}
  318. out.Result = output
  319. var buff [1024]byte
  320. ringBuffer := smithyio.NewRingBuffer(buff[:])
  321. body := io.TeeReader(response.Body, ringBuffer)
  322. decoder := json.NewDecoder(body)
  323. decoder.UseNumber()
  324. var shape interface{}
  325. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  326. var snapshot bytes.Buffer
  327. io.Copy(&snapshot, ringBuffer)
  328. err = &smithy.DeserializationError{
  329. Err: fmt.Errorf("failed to decode response body, %w", err),
  330. Snapshot: snapshot.Bytes(),
  331. }
  332. return out, metadata, err
  333. }
  334. err = awsRestjson1_deserializeOpDocumentListAccountsOutput(&output, shape)
  335. if err != nil {
  336. var snapshot bytes.Buffer
  337. io.Copy(&snapshot, ringBuffer)
  338. return out, metadata, &smithy.DeserializationError{
  339. Err: fmt.Errorf("failed to decode response body with invalid JSON, %w", err),
  340. Snapshot: snapshot.Bytes(),
  341. }
  342. }
  343. span.End()
  344. return out, metadata, err
  345. }
  346. func awsRestjson1_deserializeOpErrorListAccounts(response *smithyhttp.Response, metadata *middleware.Metadata) error {
  347. var errorBuffer bytes.Buffer
  348. if _, err := io.Copy(&errorBuffer, response.Body); err != nil {
  349. return &smithy.DeserializationError{Err: fmt.Errorf("failed to copy error response body, %w", err)}
  350. }
  351. errorBody := bytes.NewReader(errorBuffer.Bytes())
  352. errorCode := "UnknownError"
  353. errorMessage := errorCode
  354. headerCode := response.Header.Get("X-Amzn-ErrorType")
  355. if len(headerCode) != 0 {
  356. errorCode = restjson.SanitizeErrorCode(headerCode)
  357. }
  358. var buff [1024]byte
  359. ringBuffer := smithyio.NewRingBuffer(buff[:])
  360. body := io.TeeReader(errorBody, ringBuffer)
  361. decoder := json.NewDecoder(body)
  362. decoder.UseNumber()
  363. jsonCode, message, err := restjson.GetErrorInfo(decoder)
  364. if err != nil {
  365. var snapshot bytes.Buffer
  366. io.Copy(&snapshot, ringBuffer)
  367. err = &smithy.DeserializationError{
  368. Err: fmt.Errorf("failed to decode response body, %w", err),
  369. Snapshot: snapshot.Bytes(),
  370. }
  371. return err
  372. }
  373. errorBody.Seek(0, io.SeekStart)
  374. if len(headerCode) == 0 && len(jsonCode) != 0 {
  375. errorCode = restjson.SanitizeErrorCode(jsonCode)
  376. }
  377. if len(message) != 0 {
  378. errorMessage = message
  379. }
  380. switch {
  381. case strings.EqualFold("InvalidRequestException", errorCode):
  382. return awsRestjson1_deserializeErrorInvalidRequestException(response, errorBody)
  383. case strings.EqualFold("ResourceNotFoundException", errorCode):
  384. return awsRestjson1_deserializeErrorResourceNotFoundException(response, errorBody)
  385. case strings.EqualFold("TooManyRequestsException", errorCode):
  386. return awsRestjson1_deserializeErrorTooManyRequestsException(response, errorBody)
  387. case strings.EqualFold("UnauthorizedException", errorCode):
  388. return awsRestjson1_deserializeErrorUnauthorizedException(response, errorBody)
  389. default:
  390. genericError := &smithy.GenericAPIError{
  391. Code: errorCode,
  392. Message: errorMessage,
  393. }
  394. return genericError
  395. }
  396. }
  397. func awsRestjson1_deserializeOpDocumentListAccountsOutput(v **ListAccountsOutput, value interface{}) error {
  398. if v == nil {
  399. return fmt.Errorf("unexpected nil of type %T", v)
  400. }
  401. if value == nil {
  402. return nil
  403. }
  404. shape, ok := value.(map[string]interface{})
  405. if !ok {
  406. return fmt.Errorf("unexpected JSON type %v", value)
  407. }
  408. var sv *ListAccountsOutput
  409. if *v == nil {
  410. sv = &ListAccountsOutput{}
  411. } else {
  412. sv = *v
  413. }
  414. for key, value := range shape {
  415. switch key {
  416. case "accountList":
  417. if err := awsRestjson1_deserializeDocumentAccountListType(&sv.AccountList, value); err != nil {
  418. return err
  419. }
  420. case "nextToken":
  421. if value != nil {
  422. jtv, ok := value.(string)
  423. if !ok {
  424. return fmt.Errorf("expected NextTokenType to be of type string, got %T instead", value)
  425. }
  426. sv.NextToken = ptr.String(jtv)
  427. }
  428. default:
  429. _, _ = key, value
  430. }
  431. }
  432. *v = sv
  433. return nil
  434. }
  435. type awsRestjson1_deserializeOpLogout struct {
  436. }
  437. func (*awsRestjson1_deserializeOpLogout) ID() string {
  438. return "OperationDeserializer"
  439. }
  440. func (m *awsRestjson1_deserializeOpLogout) HandleDeserialize(ctx context.Context, in middleware.DeserializeInput, next middleware.DeserializeHandler) (
  441. out middleware.DeserializeOutput, metadata middleware.Metadata, err error,
  442. ) {
  443. out, metadata, err = next.HandleDeserialize(ctx, in)
  444. if err != nil {
  445. return out, metadata, err
  446. }
  447. _, span := tracing.StartSpan(ctx, "OperationDeserializer")
  448. endTimer := startMetricTimer(ctx, "client.call.deserialization_duration")
  449. defer endTimer()
  450. defer span.End()
  451. response, ok := out.RawResponse.(*smithyhttp.Response)
  452. if !ok {
  453. return out, metadata, &smithy.DeserializationError{Err: fmt.Errorf("unknown transport type %T", out.RawResponse)}
  454. }
  455. if response.StatusCode < 200 || response.StatusCode >= 300 {
  456. return out, metadata, awsRestjson1_deserializeOpErrorLogout(response, &metadata)
  457. }
  458. output := &LogoutOutput{}
  459. out.Result = output
  460. if _, err = io.Copy(ioutil.Discard, response.Body); err != nil {
  461. return out, metadata, &smithy.DeserializationError{
  462. Err: fmt.Errorf("failed to discard response body, %w", err),
  463. }
  464. }
  465. span.End()
  466. return out, metadata, err
  467. }
  468. func awsRestjson1_deserializeOpErrorLogout(response *smithyhttp.Response, metadata *middleware.Metadata) error {
  469. var errorBuffer bytes.Buffer
  470. if _, err := io.Copy(&errorBuffer, response.Body); err != nil {
  471. return &smithy.DeserializationError{Err: fmt.Errorf("failed to copy error response body, %w", err)}
  472. }
  473. errorBody := bytes.NewReader(errorBuffer.Bytes())
  474. errorCode := "UnknownError"
  475. errorMessage := errorCode
  476. headerCode := response.Header.Get("X-Amzn-ErrorType")
  477. if len(headerCode) != 0 {
  478. errorCode = restjson.SanitizeErrorCode(headerCode)
  479. }
  480. var buff [1024]byte
  481. ringBuffer := smithyio.NewRingBuffer(buff[:])
  482. body := io.TeeReader(errorBody, ringBuffer)
  483. decoder := json.NewDecoder(body)
  484. decoder.UseNumber()
  485. jsonCode, message, err := restjson.GetErrorInfo(decoder)
  486. if err != nil {
  487. var snapshot bytes.Buffer
  488. io.Copy(&snapshot, ringBuffer)
  489. err = &smithy.DeserializationError{
  490. Err: fmt.Errorf("failed to decode response body, %w", err),
  491. Snapshot: snapshot.Bytes(),
  492. }
  493. return err
  494. }
  495. errorBody.Seek(0, io.SeekStart)
  496. if len(headerCode) == 0 && len(jsonCode) != 0 {
  497. errorCode = restjson.SanitizeErrorCode(jsonCode)
  498. }
  499. if len(message) != 0 {
  500. errorMessage = message
  501. }
  502. switch {
  503. case strings.EqualFold("InvalidRequestException", errorCode):
  504. return awsRestjson1_deserializeErrorInvalidRequestException(response, errorBody)
  505. case strings.EqualFold("TooManyRequestsException", errorCode):
  506. return awsRestjson1_deserializeErrorTooManyRequestsException(response, errorBody)
  507. case strings.EqualFold("UnauthorizedException", errorCode):
  508. return awsRestjson1_deserializeErrorUnauthorizedException(response, errorBody)
  509. default:
  510. genericError := &smithy.GenericAPIError{
  511. Code: errorCode,
  512. Message: errorMessage,
  513. }
  514. return genericError
  515. }
  516. }
  517. func awsRestjson1_deserializeErrorInvalidRequestException(response *smithyhttp.Response, errorBody *bytes.Reader) error {
  518. output := &types.InvalidRequestException{}
  519. var buff [1024]byte
  520. ringBuffer := smithyio.NewRingBuffer(buff[:])
  521. body := io.TeeReader(errorBody, ringBuffer)
  522. decoder := json.NewDecoder(body)
  523. decoder.UseNumber()
  524. var shape interface{}
  525. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  526. var snapshot bytes.Buffer
  527. io.Copy(&snapshot, ringBuffer)
  528. err = &smithy.DeserializationError{
  529. Err: fmt.Errorf("failed to decode response body, %w", err),
  530. Snapshot: snapshot.Bytes(),
  531. }
  532. return err
  533. }
  534. err := awsRestjson1_deserializeDocumentInvalidRequestException(&output, shape)
  535. if err != nil {
  536. var snapshot bytes.Buffer
  537. io.Copy(&snapshot, ringBuffer)
  538. err = &smithy.DeserializationError{
  539. Err: fmt.Errorf("failed to decode response body, %w", err),
  540. Snapshot: snapshot.Bytes(),
  541. }
  542. return err
  543. }
  544. errorBody.Seek(0, io.SeekStart)
  545. return output
  546. }
  547. func awsRestjson1_deserializeErrorResourceNotFoundException(response *smithyhttp.Response, errorBody *bytes.Reader) error {
  548. output := &types.ResourceNotFoundException{}
  549. var buff [1024]byte
  550. ringBuffer := smithyio.NewRingBuffer(buff[:])
  551. body := io.TeeReader(errorBody, ringBuffer)
  552. decoder := json.NewDecoder(body)
  553. decoder.UseNumber()
  554. var shape interface{}
  555. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  556. var snapshot bytes.Buffer
  557. io.Copy(&snapshot, ringBuffer)
  558. err = &smithy.DeserializationError{
  559. Err: fmt.Errorf("failed to decode response body, %w", err),
  560. Snapshot: snapshot.Bytes(),
  561. }
  562. return err
  563. }
  564. err := awsRestjson1_deserializeDocumentResourceNotFoundException(&output, shape)
  565. if err != nil {
  566. var snapshot bytes.Buffer
  567. io.Copy(&snapshot, ringBuffer)
  568. err = &smithy.DeserializationError{
  569. Err: fmt.Errorf("failed to decode response body, %w", err),
  570. Snapshot: snapshot.Bytes(),
  571. }
  572. return err
  573. }
  574. errorBody.Seek(0, io.SeekStart)
  575. return output
  576. }
  577. func awsRestjson1_deserializeErrorTooManyRequestsException(response *smithyhttp.Response, errorBody *bytes.Reader) error {
  578. output := &types.TooManyRequestsException{}
  579. var buff [1024]byte
  580. ringBuffer := smithyio.NewRingBuffer(buff[:])
  581. body := io.TeeReader(errorBody, ringBuffer)
  582. decoder := json.NewDecoder(body)
  583. decoder.UseNumber()
  584. var shape interface{}
  585. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  586. var snapshot bytes.Buffer
  587. io.Copy(&snapshot, ringBuffer)
  588. err = &smithy.DeserializationError{
  589. Err: fmt.Errorf("failed to decode response body, %w", err),
  590. Snapshot: snapshot.Bytes(),
  591. }
  592. return err
  593. }
  594. err := awsRestjson1_deserializeDocumentTooManyRequestsException(&output, shape)
  595. if err != nil {
  596. var snapshot bytes.Buffer
  597. io.Copy(&snapshot, ringBuffer)
  598. err = &smithy.DeserializationError{
  599. Err: fmt.Errorf("failed to decode response body, %w", err),
  600. Snapshot: snapshot.Bytes(),
  601. }
  602. return err
  603. }
  604. errorBody.Seek(0, io.SeekStart)
  605. return output
  606. }
  607. func awsRestjson1_deserializeErrorUnauthorizedException(response *smithyhttp.Response, errorBody *bytes.Reader) error {
  608. output := &types.UnauthorizedException{}
  609. var buff [1024]byte
  610. ringBuffer := smithyio.NewRingBuffer(buff[:])
  611. body := io.TeeReader(errorBody, ringBuffer)
  612. decoder := json.NewDecoder(body)
  613. decoder.UseNumber()
  614. var shape interface{}
  615. if err := decoder.Decode(&shape); err != nil && err != io.EOF {
  616. var snapshot bytes.Buffer
  617. io.Copy(&snapshot, ringBuffer)
  618. err = &smithy.DeserializationError{
  619. Err: fmt.Errorf("failed to decode response body, %w", err),
  620. Snapshot: snapshot.Bytes(),
  621. }
  622. return err
  623. }
  624. err := awsRestjson1_deserializeDocumentUnauthorizedException(&output, shape)
  625. if err != nil {
  626. var snapshot bytes.Buffer
  627. io.Copy(&snapshot, ringBuffer)
  628. err = &smithy.DeserializationError{
  629. Err: fmt.Errorf("failed to decode response body, %w", err),
  630. Snapshot: snapshot.Bytes(),
  631. }
  632. return err
  633. }
  634. errorBody.Seek(0, io.SeekStart)
  635. return output
  636. }
  637. func awsRestjson1_deserializeDocumentAccountInfo(v **types.AccountInfo, value interface{}) error {
  638. if v == nil {
  639. return fmt.Errorf("unexpected nil of type %T", v)
  640. }
  641. if value == nil {
  642. return nil
  643. }
  644. shape, ok := value.(map[string]interface{})
  645. if !ok {
  646. return fmt.Errorf("unexpected JSON type %v", value)
  647. }
  648. var sv *types.AccountInfo
  649. if *v == nil {
  650. sv = &types.AccountInfo{}
  651. } else {
  652. sv = *v
  653. }
  654. for key, value := range shape {
  655. switch key {
  656. case "accountId":
  657. if value != nil {
  658. jtv, ok := value.(string)
  659. if !ok {
  660. return fmt.Errorf("expected AccountIdType to be of type string, got %T instead", value)
  661. }
  662. sv.AccountId = ptr.String(jtv)
  663. }
  664. case "accountName":
  665. if value != nil {
  666. jtv, ok := value.(string)
  667. if !ok {
  668. return fmt.Errorf("expected AccountNameType to be of type string, got %T instead", value)
  669. }
  670. sv.AccountName = ptr.String(jtv)
  671. }
  672. case "emailAddress":
  673. if value != nil {
  674. jtv, ok := value.(string)
  675. if !ok {
  676. return fmt.Errorf("expected EmailAddressType to be of type string, got %T instead", value)
  677. }
  678. sv.EmailAddress = ptr.String(jtv)
  679. }
  680. default:
  681. _, _ = key, value
  682. }
  683. }
  684. *v = sv
  685. return nil
  686. }
  687. func awsRestjson1_deserializeDocumentAccountListType(v *[]types.AccountInfo, value interface{}) error {
  688. if v == nil {
  689. return fmt.Errorf("unexpected nil of type %T", v)
  690. }
  691. if value == nil {
  692. return nil
  693. }
  694. shape, ok := value.([]interface{})
  695. if !ok {
  696. return fmt.Errorf("unexpected JSON type %v", value)
  697. }
  698. var cv []types.AccountInfo
  699. if *v == nil {
  700. cv = []types.AccountInfo{}
  701. } else {
  702. cv = *v
  703. }
  704. for _, value := range shape {
  705. var col types.AccountInfo
  706. destAddr := &col
  707. if err := awsRestjson1_deserializeDocumentAccountInfo(&destAddr, value); err != nil {
  708. return err
  709. }
  710. col = *destAddr
  711. cv = append(cv, col)
  712. }
  713. *v = cv
  714. return nil
  715. }
  716. func awsRestjson1_deserializeDocumentInvalidRequestException(v **types.InvalidRequestException, value interface{}) error {
  717. if v == nil {
  718. return fmt.Errorf("unexpected nil of type %T", v)
  719. }
  720. if value == nil {
  721. return nil
  722. }
  723. shape, ok := value.(map[string]interface{})
  724. if !ok {
  725. return fmt.Errorf("unexpected JSON type %v", value)
  726. }
  727. var sv *types.InvalidRequestException
  728. if *v == nil {
  729. sv = &types.InvalidRequestException{}
  730. } else {
  731. sv = *v
  732. }
  733. for key, value := range shape {
  734. switch key {
  735. case "message", "Message":
  736. if value != nil {
  737. jtv, ok := value.(string)
  738. if !ok {
  739. return fmt.Errorf("expected ErrorDescription to be of type string, got %T instead", value)
  740. }
  741. sv.Message = ptr.String(jtv)
  742. }
  743. default:
  744. _, _ = key, value
  745. }
  746. }
  747. *v = sv
  748. return nil
  749. }
  750. func awsRestjson1_deserializeDocumentResourceNotFoundException(v **types.ResourceNotFoundException, value interface{}) error {
  751. if v == nil {
  752. return fmt.Errorf("unexpected nil of type %T", v)
  753. }
  754. if value == nil {
  755. return nil
  756. }
  757. shape, ok := value.(map[string]interface{})
  758. if !ok {
  759. return fmt.Errorf("unexpected JSON type %v", value)
  760. }
  761. var sv *types.ResourceNotFoundException
  762. if *v == nil {
  763. sv = &types.ResourceNotFoundException{}
  764. } else {
  765. sv = *v
  766. }
  767. for key, value := range shape {
  768. switch key {
  769. case "message", "Message":
  770. if value != nil {
  771. jtv, ok := value.(string)
  772. if !ok {
  773. return fmt.Errorf("expected ErrorDescription to be of type string, got %T instead", value)
  774. }
  775. sv.Message = ptr.String(jtv)
  776. }
  777. default:
  778. _, _ = key, value
  779. }
  780. }
  781. *v = sv
  782. return nil
  783. }
  784. func awsRestjson1_deserializeDocumentRoleCredentials(v **types.RoleCredentials, value interface{}) error {
  785. if v == nil {
  786. return fmt.Errorf("unexpected nil of type %T", v)
  787. }
  788. if value == nil {
  789. return nil
  790. }
  791. shape, ok := value.(map[string]interface{})
  792. if !ok {
  793. return fmt.Errorf("unexpected JSON type %v", value)
  794. }
  795. var sv *types.RoleCredentials
  796. if *v == nil {
  797. sv = &types.RoleCredentials{}
  798. } else {
  799. sv = *v
  800. }
  801. for key, value := range shape {
  802. switch key {
  803. case "accessKeyId":
  804. if value != nil {
  805. jtv, ok := value.(string)
  806. if !ok {
  807. return fmt.Errorf("expected AccessKeyType to be of type string, got %T instead", value)
  808. }
  809. sv.AccessKeyId = ptr.String(jtv)
  810. }
  811. case "expiration":
  812. if value != nil {
  813. jtv, ok := value.(json.Number)
  814. if !ok {
  815. return fmt.Errorf("expected ExpirationTimestampType to be json.Number, got %T instead", value)
  816. }
  817. i64, err := jtv.Int64()
  818. if err != nil {
  819. return err
  820. }
  821. sv.Expiration = i64
  822. }
  823. case "secretAccessKey":
  824. if value != nil {
  825. jtv, ok := value.(string)
  826. if !ok {
  827. return fmt.Errorf("expected SecretAccessKeyType to be of type string, got %T instead", value)
  828. }
  829. sv.SecretAccessKey = ptr.String(jtv)
  830. }
  831. case "sessionToken":
  832. if value != nil {
  833. jtv, ok := value.(string)
  834. if !ok {
  835. return fmt.Errorf("expected SessionTokenType to be of type string, got %T instead", value)
  836. }
  837. sv.SessionToken = ptr.String(jtv)
  838. }
  839. default:
  840. _, _ = key, value
  841. }
  842. }
  843. *v = sv
  844. return nil
  845. }
  846. func awsRestjson1_deserializeDocumentRoleInfo(v **types.RoleInfo, value interface{}) error {
  847. if v == nil {
  848. return fmt.Errorf("unexpected nil of type %T", v)
  849. }
  850. if value == nil {
  851. return nil
  852. }
  853. shape, ok := value.(map[string]interface{})
  854. if !ok {
  855. return fmt.Errorf("unexpected JSON type %v", value)
  856. }
  857. var sv *types.RoleInfo
  858. if *v == nil {
  859. sv = &types.RoleInfo{}
  860. } else {
  861. sv = *v
  862. }
  863. for key, value := range shape {
  864. switch key {
  865. case "accountId":
  866. if value != nil {
  867. jtv, ok := value.(string)
  868. if !ok {
  869. return fmt.Errorf("expected AccountIdType to be of type string, got %T instead", value)
  870. }
  871. sv.AccountId = ptr.String(jtv)
  872. }
  873. case "roleName":
  874. if value != nil {
  875. jtv, ok := value.(string)
  876. if !ok {
  877. return fmt.Errorf("expected RoleNameType to be of type string, got %T instead", value)
  878. }
  879. sv.RoleName = ptr.String(jtv)
  880. }
  881. default:
  882. _, _ = key, value
  883. }
  884. }
  885. *v = sv
  886. return nil
  887. }
  888. func awsRestjson1_deserializeDocumentRoleListType(v *[]types.RoleInfo, value interface{}) error {
  889. if v == nil {
  890. return fmt.Errorf("unexpected nil of type %T", v)
  891. }
  892. if value == nil {
  893. return nil
  894. }
  895. shape, ok := value.([]interface{})
  896. if !ok {
  897. return fmt.Errorf("unexpected JSON type %v", value)
  898. }
  899. var cv []types.RoleInfo
  900. if *v == nil {
  901. cv = []types.RoleInfo{}
  902. } else {
  903. cv = *v
  904. }
  905. for _, value := range shape {
  906. var col types.RoleInfo
  907. destAddr := &col
  908. if err := awsRestjson1_deserializeDocumentRoleInfo(&destAddr, value); err != nil {
  909. return err
  910. }
  911. col = *destAddr
  912. cv = append(cv, col)
  913. }
  914. *v = cv
  915. return nil
  916. }
  917. func awsRestjson1_deserializeDocumentTooManyRequestsException(v **types.TooManyRequestsException, value interface{}) error {
  918. if v == nil {
  919. return fmt.Errorf("unexpected nil of type %T", v)
  920. }
  921. if value == nil {
  922. return nil
  923. }
  924. shape, ok := value.(map[string]interface{})
  925. if !ok {
  926. return fmt.Errorf("unexpected JSON type %v", value)
  927. }
  928. var sv *types.TooManyRequestsException
  929. if *v == nil {
  930. sv = &types.TooManyRequestsException{}
  931. } else {
  932. sv = *v
  933. }
  934. for key, value := range shape {
  935. switch key {
  936. case "message", "Message":
  937. if value != nil {
  938. jtv, ok := value.(string)
  939. if !ok {
  940. return fmt.Errorf("expected ErrorDescription to be of type string, got %T instead", value)
  941. }
  942. sv.Message = ptr.String(jtv)
  943. }
  944. default:
  945. _, _ = key, value
  946. }
  947. }
  948. *v = sv
  949. return nil
  950. }
  951. func awsRestjson1_deserializeDocumentUnauthorizedException(v **types.UnauthorizedException, value interface{}) error {
  952. if v == nil {
  953. return fmt.Errorf("unexpected nil of type %T", v)
  954. }
  955. if value == nil {
  956. return nil
  957. }
  958. shape, ok := value.(map[string]interface{})
  959. if !ok {
  960. return fmt.Errorf("unexpected JSON type %v", value)
  961. }
  962. var sv *types.UnauthorizedException
  963. if *v == nil {
  964. sv = &types.UnauthorizedException{}
  965. } else {
  966. sv = *v
  967. }
  968. for key, value := range shape {
  969. switch key {
  970. case "message", "Message":
  971. if value != nil {
  972. jtv, ok := value.(string)
  973. if !ok {
  974. return fmt.Errorf("expected ErrorDescription to be of type string, got %T instead", value)
  975. }
  976. sv.Message = ptr.String(jtv)
  977. }
  978. default:
  979. _, _ = key, value
  980. }
  981. }
  982. *v = sv
  983. return nil
  984. }