Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266import { Ddc } from "./ddc.ts";import { ContextBuilder } from "./context.ts";import { Context, DdcEvent, DdcOptions, DdcUserData } from "./types.ts";import { batch, Denops, ensureObject, fn, op, vars } from "./deps.ts";
type RegisterArg = { path: string; name: string; type: "source" | "filter";};
export async function main(denops: Denops) { const ddc: Ddc = new Ddc(); const contextBuilder = new ContextBuilder();
denops.dispatcher = { async register(arg1: unknown): Promise<void> { const arg = arg1 as RegisterArg; if (arg.type == "source") { await ddc.registerSource(denops, arg.path, arg.name); } else if (arg.type == "filter") { await ddc.registerFilter(denops, arg.path, arg.name); } }, alias(arg1: unknown, arg2: unknown, arg3: unknown): Promise<void> { ddc.registerAlias(arg1 as string, arg2 as string, arg3 as string); return Promise.resolve(); }, patchGlobal(arg1: unknown): Promise<void> { ensureObject(arg1); const options = arg1 as Record<string, unknown>; contextBuilder.patchGlobal(options); return Promise.resolve(); }, patchFiletype(arg1: unknown, arg2: unknown): Promise<void> { const filetype = arg1 as string; ensureObject(arg2); const options = arg2 as Record<string, unknown>; contextBuilder.patchFiletype(filetype, options); return Promise.resolve(); }, patchBuffer(arg1: unknown, arg2: unknown): Promise<void> { const bufnr = arg1 as number; ensureObject(arg2); const options = arg2 as Record<string, unknown>; contextBuilder.patchBuffer(bufnr, options); return Promise.resolve(); }, getGlobal(): Promise<Partial<DdcOptions>> { return Promise.resolve(contextBuilder.getGlobal()); }, getFiletype(): Promise<Record<string, Partial<DdcOptions>>> { return Promise.resolve(contextBuilder.getFiletype()); }, getBuffer(): Promise<Record<number, Partial<DdcOptions>>> { return Promise.resolve(contextBuilder.getBuffer()); }, async _cacheWorld(arg1: unknown): Promise<unknown> { return await contextBuilder._cacheWorld(denops, arg1 as DdcEvent); }, async manualComplete(arg1: unknown): Promise<void> { const sources = arg1 as string[];
const maybe = await contextBuilder.createContext(denops, "Manual"); if (!maybe) return; const [context, options] = maybe; if (sources.length != 0) { options.sources = sources; }
await doCompletion(denops, context, options); }, async onEvent(arg1: unknown): Promise<void> { const event = arg1 as DdcEvent; const maybe = await contextBuilder.createContext(denops, event); if (!maybe) return; const [context, options] = maybe;
await ddc.autoload(denops);
await ddc.onEvent( denops, context, options, );
if (event == "InsertLeave") { await denops.call("ddc#_clear"); return; }
const isAutoComplete = event != "AutoRefresh" && event != "ManualRefresh";
if ( isAutoComplete && await checkSkipCompletion(event, context, options) ) { await cancelCompletion(denops, context);
return; }
// Check auto complete delay. if (isAutoComplete && options.autoCompleteDelay > 0) { // Cancel previous completion await cancelCompletion(denops, context);
await new Promise((resolve) => setTimeout( resolve, options.autoCompleteDelay, ) );
const changedTick = vars.b.get(denops, "changedtick") as Promise< number >; if (context.changedTick != await changedTick) { // Input is changed. Skip invalid completion. return; } }
await doCompletion(denops, context, options); }, async onCompleteDone(arg1: unknown): Promise<void> { const userData = arg1 as DdcUserData; const maybe = await contextBuilder.createContext(denops, "CompleteDone"); if (!maybe) return; const [context, options] = maybe;
await ddc.onCompleteDone( denops, context, options, userData, ); }, };
async function checkSkipCompletion( event: DdcEvent, context: Context, options: DdcOptions, ): Promise<boolean> { // Note: Don't complete when backspace, because of completion flicker. const prevInput = await vars.g.get(denops, "ddc#_prev_input") as string; const checkBackSpace = (context.input != prevInput && context.input.length + 1 == prevInput.length && prevInput.startsWith(context.input)); if (checkBackSpace && options.completionMode == "popupmenu") { await vars.g.set(denops, "ddc#_prev_input", context.input); return true; }
// Skip special buffers. const buftype = await op.buftype.getLocal(denops); if ( buftype != "" && !options.specialBufferCompletion ) { return true; }
// Check indentkeys. const indentkeys = await op.indentkeys.getLocal(denops); for (const pattern of indentkeys.split(",")) { const found = pattern.match(/^0?=~?(.+)$/); if (!found) { continue; }
if (context.input.endsWith(found[1])) { // Skip completion and reindent if matched. await denops.call("ddc#util#indent_current_line"); return true; } }
if (options.autoCompleteEvents.indexOf(event) < 0) { return true; }
return false; }
async function cancelCompletion( denops: Denops, context: Context, ): Promise<void> { const pumvisible = await fn.pumvisible(denops);
await batch(denops, async (denops: Denops) => { await vars.g.set(denops, "ddc#_event", context.event); await vars.g.set(denops, "ddc#_complete_pos", -1); await vars.g.set(denops, "ddc#_candidates", []); if (pumvisible) { await denops.call("ddc#complete"); } }); }
async function doCompletion( denops: Denops, context: Context, options: DdcOptions, ): Promise<void> { const [completePos, candidates] = await ddc.gatherResults( denops, context, options, );
await (async function write() { const pumvisible = await fn.pumvisible(denops); const changedTick = vars.b.get(denops, "changedtick") as Promise<number>; if (context.changedTick != await changedTick) { // Input is changed. Skip invalid completion. return; }
await batch(denops, async (denops: Denops) => { await vars.g.set(denops, "ddc#_event", context.event); await vars.g.set(denops, "ddc#_prev_input", context.input); await vars.g.set(denops, "ddc#_complete_pos", completePos); await vars.g.set(denops, "ddc#_candidates", candidates); await vars.g.set( denops, "ddc#_overwrite_completeopt", options.overwriteCompleteopt, );
if ( options.completionMode == "popupmenu" || context.event == "Manual" || context.event == "AutoRefresh" || context.event == "ManualRefresh" || pumvisible ) { await denops.call("ddc#complete"); } else if (options.completionMode == "inline") { await denops.call("ddc#_inline", options.inlineHighlight); } else if (options.completionMode == "manual") { // through } }); })(); }
await batch(denops, async (denops: Denops) => { await vars.g.set(denops, "ddc#_candidates", []); await vars.g.set(denops, "ddc#_complete_pos", -1); await vars.g.set(denops, "ddc#_event", "Manual"); await vars.g.set(denops, "ddc#_now", 0); await vars.g.set(denops, "ddc#_overwrite_completeopt", false); await vars.g.set(denops, "ddc#_prev_input", "");
await denops.cmd("doautocmd <nomodeline> User DDCReady");
ddc.registerAutocmd(denops, [ "InsertEnter", "InsertLeave", "TextChangedI", "TextChangedP", ]); });}