1 /*
2 * getlocationsegments.c : entry point for get_location_segments
3 * RA functions for ra_serf
4 *
5 * ====================================================================
6 * Licensed to the Apache Software Foundation (ASF) under one
7 * or more contributor license agreements. See the NOTICE file
8 * distributed with this work for additional information
9 * regarding copyright ownership. The ASF licenses this file
10 * to you under the Apache License, Version 2.0 (the
11 * "License"); you may not use this file except in compliance
12 * with the License. You may obtain a copy of the License at
13 *
14 * http://www.apache.org/licenses/LICENSE-2.0
15 *
16 * Unless required by applicable law or agreed to in writing,
17 * software distributed under the License is distributed on an
18 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
19 * KIND, either express or implied. See the License for the
20 * specific language governing permissions and limitations
21 * under the License.
22 * ====================================================================
23 */
24
25
26
27 #include <apr_uri.h>
28 #include <serf.h>
29
30 #include "svn_hash.h"
31 #include "svn_pools.h"
32 #include "svn_ra.h"
33 #include "svn_xml.h"
34 #include "svn_path.h"
35 #include "svn_private_config.h"
36 #include "../libsvn_ra/ra_loader.h"
37
38 #include "ra_serf.h"
39
40
41
42 typedef struct gls_context_t {
43 /* parameters set by our caller */
44 svn_revnum_t peg_revision;
45 svn_revnum_t start_rev;
46 svn_revnum_t end_rev;
47 const char *path;
48
49 /* location segment callback function/baton */
50 svn_location_segment_receiver_t receiver;
51 void *receiver_baton;
52
53 } gls_context_t;
54
55 enum locseg_state_e {
56 INITIAL = XML_STATE_INITIAL,
57 REPORT,
58 SEGMENT
59 };
60
61 #define D_ "DAV:"
62 #define S_ SVN_XML_NAMESPACE
63 static const svn_ra_serf__xml_transition_t gls_ttable[] = {
64 { INITIAL, S_, "get-location-segments-report", REPORT,
65 FALSE, { NULL }, FALSE },
66
67 { REPORT, S_, "location-segment", SEGMENT,
68 FALSE, { "?path", "range-start", "range-end", NULL }, TRUE },
69
70 { 0 }
71 };
72
73
74 /* Conforms to svn_ra_serf__xml_closed_t */
75 static svn_error_t *
gls_closed(svn_ra_serf__xml_estate_t * xes,void * baton,int leaving_state,const svn_string_t * cdata,apr_hash_t * attrs,apr_pool_t * scratch_pool)76 gls_closed(svn_ra_serf__xml_estate_t *xes,
77 void *baton,
78 int leaving_state,
79 const svn_string_t *cdata,
80 apr_hash_t *attrs,
81 apr_pool_t *scratch_pool)
82 {
83 gls_context_t *gls_ctx = baton;
84 const char *path;
85 const char *start_str;
86 const char *end_str;
87 apr_int64_t start_val;
88 apr_int64_t end_val;
89 svn_location_segment_t segment;
90
91 SVN_ERR_ASSERT(leaving_state == SEGMENT);
92
93 path = svn_hash_gets(attrs, "path");
94 start_str = svn_hash_gets(attrs, "range-start");
95 end_str = svn_hash_gets(attrs, "range-end");
96
97 /* The transition table said these must exist. */
98 SVN_ERR_ASSERT(start_str && end_str);
99
100 SVN_ERR(svn_cstring_atoi64(&start_val, start_str));
101 SVN_ERR(svn_cstring_atoi64(&end_val, end_str));
102
103 segment.path = path; /* may be NULL */
104 segment.range_start = (svn_revnum_t)start_val;
105 segment.range_end = (svn_revnum_t)end_val;
106 SVN_ERR(gls_ctx->receiver(&segment, gls_ctx->receiver_baton, scratch_pool));
107
108 return SVN_NO_ERROR;
109 }
110
111
112 /* Implements svn_ra_serf__request_body_delegate_t */
113 static svn_error_t *
create_gls_body(serf_bucket_t ** body_bkt,void * baton,serf_bucket_alloc_t * alloc,apr_pool_t * pool,apr_pool_t * scratch_pool)114 create_gls_body(serf_bucket_t **body_bkt,
115 void *baton,
116 serf_bucket_alloc_t *alloc,
117 apr_pool_t *pool /* request pool */,
118 apr_pool_t *scratch_pool)
119 {
120 serf_bucket_t *buckets;
121 gls_context_t *gls_ctx = baton;
122
123 buckets = serf_bucket_aggregate_create(alloc);
124
125 svn_ra_serf__add_open_tag_buckets(buckets, alloc,
126 "S:get-location-segments",
127 "xmlns:S", SVN_XML_NAMESPACE,
128 SVN_VA_NULL);
129
130 svn_ra_serf__add_tag_buckets(buckets,
131 "S:path", gls_ctx->path,
132 alloc);
133
134 svn_ra_serf__add_tag_buckets(buckets,
135 "S:peg-revision",
136 apr_ltoa(pool, gls_ctx->peg_revision),
137 alloc);
138
139 svn_ra_serf__add_tag_buckets(buckets,
140 "S:start-revision",
141 apr_ltoa(pool, gls_ctx->start_rev),
142 alloc);
143
144 svn_ra_serf__add_tag_buckets(buckets,
145 "S:end-revision",
146 apr_ltoa(pool, gls_ctx->end_rev),
147 alloc);
148
149 svn_ra_serf__add_close_tag_buckets(buckets, alloc,
150 "S:get-location-segments");
151
152 *body_bkt = buckets;
153 return SVN_NO_ERROR;
154 }
155
156 svn_error_t *
svn_ra_serf__get_location_segments(svn_ra_session_t * ra_session,const char * path,svn_revnum_t peg_revision,svn_revnum_t start_rev,svn_revnum_t end_rev,svn_location_segment_receiver_t receiver,void * receiver_baton,apr_pool_t * pool)157 svn_ra_serf__get_location_segments(svn_ra_session_t *ra_session,
158 const char *path,
159 svn_revnum_t peg_revision,
160 svn_revnum_t start_rev,
161 svn_revnum_t end_rev,
162 svn_location_segment_receiver_t receiver,
163 void *receiver_baton,
164 apr_pool_t *pool)
165 {
166 gls_context_t *gls_ctx;
167 svn_ra_serf__session_t *session = ra_session->priv;
168 svn_ra_serf__handler_t *handler;
169 svn_ra_serf__xml_context_t *xmlctx;
170 const char *req_url;
171 svn_error_t *err;
172
173 gls_ctx = apr_pcalloc(pool, sizeof(*gls_ctx));
174 gls_ctx->path = path;
175 gls_ctx->peg_revision = peg_revision;
176 gls_ctx->start_rev = start_rev;
177 gls_ctx->end_rev = end_rev;
178 gls_ctx->receiver = receiver;
179 gls_ctx->receiver_baton = receiver_baton;
180
181 SVN_ERR(svn_ra_serf__get_stable_url(&req_url, NULL /* latest_revnum */,
182 session, NULL /* url */, peg_revision,
183 pool, pool));
184
185 xmlctx = svn_ra_serf__xml_context_create(gls_ttable,
186 NULL, gls_closed, NULL,
187 gls_ctx,
188 pool);
189 handler = svn_ra_serf__create_expat_handler(session, xmlctx, NULL, pool);
190
191 handler->method = "REPORT";
192 handler->path = req_url;
193 handler->body_delegate = create_gls_body;
194 handler->body_delegate_baton = gls_ctx;
195 handler->body_type = "text/xml";
196
197 err = svn_ra_serf__context_run_one(handler, pool);
198
199 if (!err && handler->sline.code != 200)
200 err = svn_ra_serf__unexpected_status(handler);
201
202 if (err && (err->apr_err == SVN_ERR_UNSUPPORTED_FEATURE))
203 return svn_error_create(SVN_ERR_RA_NOT_IMPLEMENTED, err, NULL);
204
205 return svn_error_trace(err);
206 }
207