@@ -125,66 +125,53 @@ async function getFlowInfo(req, res) {
125
125
) ;
126
126
return ;
127
127
}
128
- if ( sub . subUserinfo ) {
129
- try {
130
- const remainingDays = getRmainingDays ( {
131
- resetDay : $arguments . resetDay ,
132
- startDate : $arguments . startDate ,
133
- cycleDays : $arguments . cycleDays ,
134
- } ) ;
135
- const result = {
136
- ...parseFlowHeaders ( sub . subUserinfo ) ,
137
- } ;
138
- if ( remainingDays != null ) {
139
- result . remainingDays = remainingDays ;
140
- }
141
- success ( res , result ) ;
142
- } catch ( e ) {
143
- $ . error (
144
- `Failed to parse flow info for local subscription ${ name } : ${
145
- e . message ?? e
146
- } `,
147
- ) ;
148
- failed (
149
- res ,
150
- new RequestInvalidError (
151
- 'NO_FLOW_INFO' ,
152
- 'N/A' ,
153
- `Failed to parse flow info` ,
154
- ) ,
155
- ) ;
156
- }
157
- } else {
158
- const flowHeaders = await getFlowHeaders (
159
- $arguments ?. insecure ? `${ url } #insecure` : url ,
160
- $arguments . flowUserAgent ,
161
- undefined ,
162
- sub . proxy ,
163
- $arguments . flowUrl ,
128
+ const flowHeaders = await getFlowHeaders (
129
+ $arguments ?. insecure ? `${ url } #insecure` : url ,
130
+ $arguments . flowUserAgent ,
131
+ undefined ,
132
+ sub . proxy ,
133
+ $arguments . flowUrl ,
134
+ ) ;
135
+ if ( ! flowHeaders && ! sub . subUserinfo ) {
136
+ failed (
137
+ res ,
138
+ new InternalServerError (
139
+ 'NO_FLOW_INFO' ,
140
+ 'No flow info' ,
141
+ `Failed to fetch flow headers` ,
142
+ ) ,
164
143
) ;
165
- if ( ! flowHeaders ) {
166
- failed (
167
- res ,
168
- new InternalServerError (
169
- 'NO_FLOW_INFO' ,
170
- 'No flow info' ,
171
- `Failed to fetch flow headers` ,
172
- ) ,
173
- ) ;
174
- return ;
175
- }
144
+ return ;
145
+ }
146
+ try {
176
147
const remainingDays = getRmainingDays ( {
177
148
resetDay : $arguments . resetDay ,
178
149
startDate : $arguments . startDate ,
179
150
cycleDays : $arguments . cycleDays ,
180
151
} ) ;
181
152
const result = {
182
- ...parseFlowHeaders ( flowHeaders ) ,
153
+ ...parseFlowHeaders (
154
+ [ sub . subUserinfo , flowHeaders ] . filter ( ( i ) => i ) . join ( '; ' ) ,
155
+ ) ,
183
156
} ;
184
157
if ( remainingDays != null ) {
185
158
result . remainingDays = remainingDays ;
186
159
}
187
160
success ( res , result ) ;
161
+ } catch ( e ) {
162
+ $ . error (
163
+ `Failed to parse flow info for local subscription ${ name } : ${
164
+ e . message ?? e
165
+ } `,
166
+ ) ;
167
+ failed (
168
+ res ,
169
+ new RequestInvalidError (
170
+ 'NO_FLOW_INFO' ,
171
+ 'N/A' ,
172
+ `Failed to parse flow info` ,
173
+ ) ,
174
+ ) ;
188
175
}
189
176
} catch ( err ) {
190
177
failed (
0 commit comments