Chat API

ChatMessageSendResponse send(ChatMessageSendRequest sendRequest);

Flux<ChatMessageSendCompletionResponse> sendChatMessageStream(ChatMessageSendRequest sendRequest);

void stopMessagesStream(String apiKey, String taskId, String userId);

MessageFeedbackResponse messageFeedback(MessageFeedbackRequest messageFeedbackRequest);

DifyPageResult<MessagesResponseVO> messages(MessagesRequest request);

List<String> messagesSuggested(String messageId, String apiKey, String userId);

DifyPageResult<AppFeedbackResponse> feedbacks(AppFeedbackPageRequest request);

DifyPageResult<ConversationVariableResponse> conversationVariables(ConversationVariableRequest request);

ConversationVariableResponse updateConversationVariable(UpdateConversationVariableRequest request);

DifyPageResult<MessageConversationsResponse> conversations(MessageConversationsRequest request);

void deleteConversation(String conversationId, String apiKey, String userId);

MessageConversationsResponse renameConversation(RenameConversationRequest renameConversationRequest);

ResponseEntity<byte[]> textToAudio(TextToAudioRequest request);

import java.io.IOException;

private void textToAudio(TextToAudioRequest request, HttpServletResponse response) {
    try {
        ResponseEntity<byte[]> responseEntity = difyChat.textToAudio(request);

        String type = responseEntity.getHeaders().getFirst(HttpHeaders.CONTENT_TYPE);
        response.setContentType(type != null ? type : "audio/mpeg");

        String contentDisposition = responseEntity.getHeaders().getFirst(HttpHeaders.CONTENT_DISPOSITION);
        if (contentDisposition != null) {
            response.setHeader(HttpHeaders.CONTENT_DISPOSITION, contentDisposition);
        } else {
            response.setHeader(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=audio.mp3");
        }

        if (responseEntity.getBody() != null) {
            response.getOutputStream().write(responseEntity.getBody());
            response.getOutputStream().flush();
        }

    } catch (Exception e) {
        log.error("textToAudio error: {}", e.getMessage());
        throw new RuntimeException("textToAudio error");
    }
}

DifyTextVO audioToText(AudioToTextRequest request);

AppParametersResponseVO parameters(String apiKey);

FileUploadResponse fileUpload(FileUploadRequest request);

AppInfoResponse info(String apiKey);

AppMetaResponse meta(String apiKey);

AppSiteResponse site(String apikey);

ResponseEntity<byte[]> filePreview(FilePreviewRequest request);

// 创建文件预览请求
FilePreviewRequest request = new FilePreviewRequest("file-id-123")
                .setApiKey("your-api-key")
                .setUserId("user-123");

// 执行文件预览
ResponseEntity<byte[]> response = difyChat.filePreview(request);

// 获取文件内容
byte[] fileContent = response.getBody();

import java.io.IOException;
import javax.servlet.http.HttpServletResponse;

private void previewFile(String fileId, HttpServletResponse response) {
    try {
        FilePreviewRequest request = new FilePreviewRequest(fileId)
                .setApiKey("your-api-key")
                .setUserId("user-123")
                .setAsAttachment(false); // 在浏览器中预览

        ResponseEntity<byte[]> responseEntity = difyChat.filePreview(request);

        // 设置响应头
        String contentType = responseEntity.getHeaders().getFirst(HttpHeaders.CONTENT_TYPE);
        response.setContentType(contentType != null ? contentType : "application/octet-stream");

        String contentLength = responseEntity.getHeaders().getFirst(HttpHeaders.CONTENT_LENGTH);
        if (contentLength != null) {
            response.setContentLength(Integer.parseInt(contentLength));
        }

        // 复制缓存控制头
        String cacheControl = responseEntity.getHeaders().getFirst(HttpHeaders.CACHE_CONTROL);
        if (cacheControl != null) {
            response.setHeader(HttpHeaders.CACHE_CONTROL, cacheControl);
        }

        // 写入文件内容
        if (responseEntity.getBody() != null) {
            response.getOutputStream().write(responseEntity.getBody());
            response.getOutputStream().flush();
        }

    } catch (Exception e) {
        log.error("File preview error: {}", e.getMessage());
        response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
    }
}

import java.io.IOException;
import javax.servlet.http.HttpServletResponse;

private void downloadFile(String fileId, String filename, HttpServletResponse response) {
    try {
        FilePreviewRequest request = new FilePreviewRequest(fileId, true, "your-api-key", "user-123");

        ResponseEntity<byte[]> responseEntity = difyChat.filePreview(request);

        // 设置响应头
        String contentType = responseEntity.getHeaders().getFirst(HttpHeaders.CONTENT_TYPE);
        response.setContentType(contentType != null ? contentType : "application/octet-stream");

        String contentDisposition = responseEntity.getHeaders().getFirst(HttpHeaders.CONTENT_DISPOSITION);
        if (contentDisposition != null) {
            response.setHeader(HttpHeaders.CONTENT_DISPOSITION, contentDisposition);
        } else {
            // 设置自定义文件名
            String safeFilename = filename != null ? filename : "download";
            response.setHeader(HttpHeaders.CONTENT_DISPOSITION,
                    "attachment; filename=\"" + safeFilename + "\"");
        }

        // 写入文件内容
        if (responseEntity.getBody() != null) {
            response.getOutputStream().write(responseEntity.getBody());
            response.getOutputStream().flush();
        }

    } catch (Exception e) {
        log.error("File download error: {}", e.getMessage());
        response.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
    }
}

DifyPageResult<AppAnnotationResponse> pageAppAnnotation(AppAnnotationPageRequest request);

AppAnnotationResponse createAppAnnotation(AppAnnotationCreateRequest request);

AppAnnotationResponse updateAppAnnotation(AppAnnotationUpdateRequest request);

 void deleteAppAnnotation(String annotationId, String apiKey);

AppAnnotationReplyResponse annotationReply(AppAnnotationReplyRequest request);

AppAnnotationReplyResponse queryAnnotationReply(AppAnnotationReplyQueryRequest request);