common_request.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. package requests
  2. import (
  3. "bytes"
  4. "fmt"
  5. "io"
  6. "sort"
  7. "strings"
  8. )
  9. type CommonRequest struct {
  10. *baseRequest
  11. Version string
  12. ApiName string
  13. Product string
  14. ServiceCode string
  15. // roa params
  16. PathPattern string
  17. PathParams map[string]string
  18. Ontology AcsRequest
  19. }
  20. func NewCommonRequest() (request *CommonRequest) {
  21. request = &CommonRequest{
  22. baseRequest: defaultBaseRequest(),
  23. }
  24. request.Headers["x-sdk-invoke-type"] = "common"
  25. request.PathParams = make(map[string]string)
  26. return
  27. }
  28. func (request *CommonRequest) String() string {
  29. request.TransToAcsRequest()
  30. resultBuilder := bytes.Buffer{}
  31. mapOutput := func(m map[string]string) {
  32. if len(m) > 0 {
  33. sortedKeys := make([]string, 0)
  34. for k := range m {
  35. sortedKeys = append(sortedKeys, k)
  36. }
  37. // sort 'string' key in increasing order
  38. sort.Strings(sortedKeys)
  39. for _, key := range sortedKeys {
  40. resultBuilder.WriteString(key + ": " + m[key] + "\n")
  41. }
  42. }
  43. }
  44. // Request Line
  45. resultBuilder.WriteString(fmt.Sprintf("%s %s %s/1.1\n", request.Method, request.BuildQueries(), strings.ToUpper(request.Scheme)))
  46. // Headers
  47. resultBuilder.WriteString("Host" + ": " + request.Domain + "\n")
  48. mapOutput(request.Headers)
  49. resultBuilder.WriteString("\n")
  50. // Body
  51. if len(request.Content) > 0 {
  52. resultBuilder.WriteString(string(request.Content) + "\n")
  53. } else {
  54. mapOutput(request.FormParams)
  55. }
  56. return resultBuilder.String()
  57. }
  58. func (request *CommonRequest) TransToAcsRequest() {
  59. if len(request.PathPattern) > 0 {
  60. roaRequest := &RoaRequest{}
  61. roaRequest.initWithCommonRequest(request)
  62. request.Ontology = roaRequest
  63. } else {
  64. rpcRequest := &RpcRequest{}
  65. rpcRequest.baseRequest = request.baseRequest
  66. rpcRequest.product = request.Product
  67. rpcRequest.version = request.Version
  68. rpcRequest.locationServiceCode = request.ServiceCode
  69. rpcRequest.actionName = request.ApiName
  70. request.Ontology = rpcRequest
  71. }
  72. }
  73. func (request *CommonRequest) BuildUrl() string {
  74. return request.Ontology.BuildUrl()
  75. }
  76. func (request *CommonRequest) BuildQueries() string {
  77. return request.Ontology.BuildQueries()
  78. }
  79. func (request *CommonRequest) GetBodyReader() io.Reader {
  80. return request.Ontology.GetBodyReader()
  81. }
  82. func (request *CommonRequest) GetStyle() string {
  83. return request.Ontology.GetStyle()
  84. }
  85. func (request *CommonRequest) addPathParam(key, value string) {
  86. request.PathParams[key] = value
  87. }