@SpringBootApplication
@EnablePmWebClient("cn.pinming")
public class WebClientTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(WebClientTestApplication.class, args);
    }
}

/**
 * @author <a href="mailto:luojianwei@pinming.cn">LuoJianwei</a>
 * @since 2020/10/27 18:18
 */
@ApiServer("${user.api.baseUrl}")
public interface IUserApi {

	@GetMapping("/")
	Flux<User> getAllUser();

	@GetMapping("/{id}")
	Mono<User> getUserById(@PathVariable("id") String id);

	@DeleteMapping("/{id}")
	Mono<Void> deleteUserById(@PathVariable("id") String id);

	@PostMapping("/")
	Mono<User> createUser(@RequestBody Mono<User> user);

	@PostMapping("/form")
	Mono<String> createUserByForm(@RequestForm Mono<MultiValueMap<String, ?>> param, @RequestHeader("accessToken") String token, @RequestHeader Map<String,String> headers);

	@PostMapping("/")
	Mono<String> createUserByRawBody(@PlainRequestBody Mono<String> body);
}

/**
 * @author <a href="mailto:luojianwei@pinming.cn">LuoJianwei</a>
 * @since 2020/10/26 18:17
 */
@Component
@Slf4j
public class TestInterceptor implements Interceptor {
    @Override
    public boolean applyPre(ClientRequest clientRequest) {
        int i = ThreadLocalRandom.current().nextInt();
        if (i % 2 == 0){
            return true;
        }
        return false;
    }

    @Override
    public void applyPost(ClientRequest clientRequest, ClientResponse clientResponse, RequestInfo requestInfo) {
        log.info(requestInfo.toString());
    }

    @Override
    public void applyError(ClientRequest clientRequest, ClientResponse clientResponse, RequestInfo requestInfo) {
        log.info(requestInfo.toString());
    }
}

/**
 * @author <a href="mailto:luojianwei@pinming.cn">LuoJianwei</a>
 * @since 2020/10/22 13:54
 */
@ConfigurationProperties("pm.webclient")
@Data
public class PmWebClientProperties {
    /**
     * the maximum number of connections before starting pending
     */
    private int maxConnections = 100;
    /**
     * the maximum time in millis to wait for acquiring
     */
    private long acquireTimeout = 3000;
    /**
     * the event loop thread name prefix
     */
    private String eventLoopThreadPrefix = "pm-event-loop-";
    /**
     * number of selector threads
     */
    private int selectCount = 1;
    /**
     * number of worker threads
     */
    private int workerCount = 4;
    /**
     * read timeout in seconds
     */
    private int readTimeoutSeconds = 6;
    /**
     * write timeout in seconds
     */
    private int writeTimeoutSeconds = 6;
    /**
     *  connect timeout in seconds
     */
    private int connectTimeoutSeconds = 6;
    /**
     * max in memory size in MegaByte
     */
    private int maxInMemorySizeMegaByte = 10;
}