diff --git a/.obsidian/plugins/halo/main.js b/.obsidian/plugins/halo/main.js index 9f9c15f..7c6b05c 100644 --- a/.obsidian/plugins/halo/main.js +++ b/.obsidian/plugins/halo/main.js @@ -65,7 +65,7 @@ let __rslib_import_meta_url__=function(){return"undefined"==typeof document?new( title: ${n} --- -${u}`,l=`${n}.md`,h=await e.app.vault.create(l,r);e.app.workspace.getLeaf().openFile(h),new V.Notice($.t("export.notice_export_success",{fileName:l}))}catch(e){console.error("[HaloPlugin] Export as markdown failed:",e),new V.Notice($.t("export.error_export_failed"))}}async function eJ(e,t,n){try{var i,a,o,s,u;let r=e.settings.sites[0];e.settings.sites.length>1&&(r=await ec(e));let l={Authorization:`Bearer ${r.token}`},h=await (0,V.requestUrl)({url:`${r.url}/apis/uc.api.content.halo.run/v1alpha1/posts/${t}`,headers:l}).json,g=await (0,V.requestUrl)({url:`${r.url}/apis/uc.api.content.halo.run/v1alpha1/posts/${t}/draft?patched=true`,headers:l}).json,c={post:h,content:{raw:(null==g?void 0:null===(a=g.metadata)||void 0===a?void 0:null===(i=a.annotations)||void 0===i?void 0:i["content.halo.run/patched-raw"])||"",content:(null==g?void 0:null===(s=g.metadata)||void 0===s?void 0:null===(o=s.annotations)||void 0===o?void 0:o["content.halo.run/patched-content"])||"",rawType:(null==g?void 0:null===(u=g.spec)||void 0===u?void 0:u.rawType)||"markdown"},exportedAt:new Date().toISOString()},d=`${n}.json`,p=await e.app.vault.create(d,JSON.stringify(c,null,2));e.app.workspace.getLeaf().openFile(p),new V.Notice($.t("export.notice_export_success",{fileName:d}))}catch(e){console.error("[HaloPlugin] Export as JSON failed:",e),new V.Notice($.t("export.error_export_failed"))}}function eT(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function eZ(e,t){new eX(e,t).open()}class eX extends V.Modal{async onOpen(){let{contentEl:e}=this;e.empty(),e.createEl("h2",{text:$.t("search_modal.title")}),new V.Setting(e).setName($.t("search_modal.search_placeholder")).addText(e=>{e.setPlaceholder($.t("search_modal.search_placeholder")).onChange(e=>{this.searchKeyword=e,this.filterPosts(),this.renderResults()})});let t=e.createDiv("search-filter");t.createEl("button",{text:$.t("post_selection_modal.filter_all"),cls:"all"===this.filter?"active":""}).addEventListener("click",async()=>{this.filter="all",await this.loadPosts(),this.renderResults()}),t.createEl("button",{text:$.t("post_selection_modal.filter_published"),cls:"published"===this.filter?"active":""}).addEventListener("click",async()=>{this.filter="published",await this.loadPosts(),this.renderResults()}),t.createEl("button",{text:$.t("post_selection_modal.filter_draft"),cls:"draft"===this.filter?"active":""}).addEventListener("click",async()=>{this.filter="draft",await this.loadPosts(),this.renderResults()}),e.createDiv("search-results").createEl("p",{text:$.t("search_modal.loading")}),await this.loadPosts(),this.renderResults()}async loadPosts(){try{let e="content.halo.run/deleted=false";"published"===this.filter?e="content.halo.run/deleted=false,content.halo.run/published=true":"draft"===this.filter&&(e="content.halo.run/deleted=false,content.halo.run/published=false");let t=await (0,V.requestUrl)({url:`${this.site.url}/apis/uc.api.content.halo.run/v1alpha1/posts?labelSelector=${encodeURIComponent(e)}&size=100`,headers:{Authorization:`Bearer ${this.site.token}`}});this.posts=t.json.items||[],this.filterPosts()}catch(e){new V.Notice($.t("common.error_connection_failed"))}}filterPosts(){if(!this.searchKeyword){this.filteredPosts=this.posts;return}let e=this.searchKeyword.toLowerCase();this.filteredPosts=this.posts.filter(t=>{let n=(t.post.spec.title||"").toLowerCase(),i=(t.post.spec.slug||"").toLowerCase();return n.includes(e)||i.includes(e)})}renderResults(){let{contentEl:e}=this,t=e.querySelector(".search-results");if(t){if(t.empty(),0===this.filteredPosts.length){t.createEl("p",{text:$.t("search_modal.no_results")});return}for(let e of(t.createEl("p",{text:$.t("search_modal.result_count",{count:this.filteredPosts.length}),cls:"result-count"}),this.filteredPosts))this.renderPostItem(e,t)}}renderPostItem(e,t){let n=t.createDiv("search-result-item"),i=n.createDiv("result-header");i.createEl("h3",{text:e.post.spec.title||$.t("post_selection_modal.untitled")}),i.createSpan({text:e.post.spec.publish?$.t("post_selection_modal.status_published"):$.t("post_selection_modal.status_draft"),cls:e.post.spec.publish?"status-published":"status-draft"});let a=n.createDiv("result-meta");a.createEl("span",{text:`Slug: ${e.post.spec.slug}`}),a.createEl("span",{text:` | ${new Date(e.post.metadata.creationTimestamp).toLocaleDateString()}`});let o=n.createDiv("result-actions");o.createEl("button",{text:$.t("search_modal.button_view")}).addEventListener("click",()=>{window.open(`${this.site.url}/archives/${e.post.spec.slug}`,"_blank")}),o.createEl("button",{text:$.t("search_modal.button_export_md")}).addEventListener("click",async()=>{await eB(this.plugin,e.post.metadata.name,e.post.spec.title)}),o.createEl("button",{text:$.t("search_modal.button_export_json")}).addEventListener("click",async()=>{await eJ(this.plugin,e.post.metadata.name,e.post.spec.title)})}onClose(){let{contentEl:e}=this;e.empty()}constructor(e,t){super(app),eT(this,"plugin",void 0),eT(this,"site",void 0),eT(this,"posts",void 0),eT(this,"filteredPosts",void 0),eT(this,"searchKeyword",void 0),eT(this,"filter",void 0),this.plugin=e,this.site=t,this.posts=[],this.filteredPosts=[],this.searchKeyword="",this.filter="all"}}async function eN(e){try{if(0===e.settings.sites.length){new V.Notice($.t("command.pull_post.error_no_sites"));return}let t=e.settings.sites[0];e.settings.sites.length>1&&(t=await ec(e)),eZ(e,t)}catch(e){console.error("[HaloPlugin] Search posts failed:",e),new V.Notice($.t("common.error_connection_failed"))}}function eH(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}let eM="halo-sync-status";class eQ extends V.ItemView{getViewType(){return eM}getDisplayText(){return $.t("sync_panel.title")}async onOpen(){this.render()}loadHistory(){let e=this.plugin.loadData();this.history=(null==e?void 0:e.syncHistory)||[]}saveHistory(){let e=this.plugin.loadData()||{};e.syncHistory=this.history.slice(-50),this.plugin.saveData(e)}addToHistory(e,t,n){this.history.push({id:Date.now().toString(),action:e,title:t,timestamp:Date.now(),success:n}),this.saveHistory()}getPublishedPosts(){let e=[];for(let o of this.plugin.app.vault.getFiles()){var t,n,i,a;if("md"!==o.extension)continue;let s=this.plugin.app.metadataCache.getFileCache(o);if(!(null==s?void 0:null===(n=s.frontmatter)||void 0===n?void 0:null===(t=n.halo)||void 0===t?void 0:t.name))continue;let u=null!==(i=s.frontmatter.halo.publish)&&void 0!==i&&i,r=null!==(a=s.frontmatter.halo.localModified)&&void 0!==a&&a,l="synced";u?r&&(l="local-modified"):l="unpublished";let h=this.extractCategories(s.frontmatter);e.push({file:o,title:s.frontmatter.title||o.basename,slug:s.frontmatter.slug||"",haloName:s.frontmatter.halo.name,haloSite:s.frontmatter.halo.site||"",publishStatus:u,syncStatus:l,categories:h,tags:this.extractTags(s.frontmatter),localModified:o.stat.mtime,remoteModified:s.frontmatter.halo.remoteModified})}return e}extractCategories(e){let t=[];return e.categories&&(Array.isArray(e.categories)?t.push(...e.categories.map(String)):t.push(String(e.categories))),t.length>0?t:["未分类"]}extractTags(e){let t=[];if(e.tags){if(Array.isArray(e.tags))t.push(...e.tags.map(String));else if("string"==typeof e.tags){let n=e.tags.replace(/[\[\]]/g,"").split(",").map(e=>e.trim());t.push(...n.filter(Boolean))}}return t}groupPostsByCategory(e){let t=new Map;for(let n of e){let e=n.categories[0]||"未分类";!t.has(e)&&t.set(e,[]),t.get(e).push(n)}return Array.from(t.entries()).map(([e,t])=>({category:e,posts:t})).sort((e,t)=>"未分类"===e.category?1:"未分类"===t.category?-1:e.category.localeCompare(t.category))}filterPosts(e){let t=e;if(this.searchQuery){let e=this.searchQuery.toLowerCase();t=t.filter(t=>t.title.toLowerCase().includes(e)||t.slug.toLowerCase().includes(e)||t.categories.some(t=>t.toLowerCase().includes(e))||t.tags.some(t=>t.toLowerCase().includes(e)))}switch(this.filterMode){case"synced":return t.filter(e=>"synced"===e.syncStatus);case"pending":return t.filter(e=>"synced"!==e.syncStatus);default:return t}}getStatusIcon(e){switch(e){case"synced":return"\uD83D\uDFE2";case"local-modified":return"\uD83D\uDFE1";case"remote-updated":return"\uD83D\uDD35";case"unpublished":return"⚪"}}getStatusText(e){switch(e){case"synced":return $.t("sync_panel.status_synced");case"local-modified":return $.t("sync_panel.status_local_modified");case"remote-updated":return $.t("sync_panel.status_remote_updated");case"unpublished":return $.t("sync_panel.status_unpublished")}}formatRelativeTime(e){let t=Date.now()-e,n=Math.floor(t/6e4),i=Math.floor(t/36e5),a=Math.floor(t/864e5);return n<1?$.t("sync_panel.time_just_now"):n<60?$.t("sync_panel.time_minutes_ago",{count:n}):i<24?$.t("sync_panel.time_hours_ago",{count:i}):$.t("sync_panel.time_days_ago",{count:a})}async performAction(e,t){let n=this.plugin.settings.sites.find(t=>t.url===e.haloSite);if(!n){new V.Notice($.t("service.error_site_not_match"));return}let{default:i}=await Promise.resolve().then(__webpack_require__.bind(__webpack_require__,"./src/service/index.ts")),a=new i(this.plugin.app,this.plugin.settings,n);try{switch(t){case"update":await a.updatePost(),this.addToHistory("update",e.title,!0),new V.Notice($.t("command.update_post.success"));break;case"publish":await a.publishPost(),this.addToHistory("publish",e.title,!0),new V.Notice($.t("service.notice_publish_success"));break;case"pull":await a.pullPost(e.haloName),this.addToHistory("pull",e.title,!0)}this.render()}catch(n){this.addToHistory(t,e.title,!1),new V.Notice($.t("service.error_publish_failed"))}}renderPostDetail(e){let t=document.createElement("div");t.className="sync-detail-modal",t.style.cssText=` +${u}`,l=`${n}.md`,h=await e.app.vault.create(l,r);e.app.workspace.getLeaf().openFile(h),new V.Notice($.t("export.notice_export_success",{fileName:l}))}catch(e){console.error("[HaloPlugin] Export as markdown failed:",e),new V.Notice($.t("export.error_export_failed"))}}async function eJ(e,t,n){try{var i,a,o,s,u;let r=e.settings.sites[0];e.settings.sites.length>1&&(r=await ec(e));let l={Authorization:`Bearer ${r.token}`},h=await (0,V.requestUrl)({url:`${r.url}/apis/uc.api.content.halo.run/v1alpha1/posts/${t}`,headers:l}).json,g=await (0,V.requestUrl)({url:`${r.url}/apis/uc.api.content.halo.run/v1alpha1/posts/${t}/draft?patched=true`,headers:l}).json,c={post:h,content:{raw:(null==g?void 0:null===(a=g.metadata)||void 0===a?void 0:null===(i=a.annotations)||void 0===i?void 0:i["content.halo.run/patched-raw"])||"",content:(null==g?void 0:null===(s=g.metadata)||void 0===s?void 0:null===(o=s.annotations)||void 0===o?void 0:o["content.halo.run/patched-content"])||"",rawType:(null==g?void 0:null===(u=g.spec)||void 0===u?void 0:u.rawType)||"markdown"},exportedAt:new Date().toISOString()},d=`${n}.json`,p=await e.app.vault.create(d,JSON.stringify(c,null,2));e.app.workspace.getLeaf().openFile(p),new V.Notice($.t("export.notice_export_success",{fileName:d}))}catch(e){console.error("[HaloPlugin] Export as JSON failed:",e),new V.Notice($.t("export.error_export_failed"))}}function eT(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function eZ(e,t){new eX(e,t).open()}class eX extends V.Modal{async onOpen(){let{contentEl:e}=this;e.empty(),e.createEl("h2",{text:$.t("search_modal.title")}),new V.Setting(e).setName($.t("search_modal.search_placeholder")).addText(e=>{e.setPlaceholder($.t("search_modal.search_placeholder")).onChange(e=>{this.searchKeyword=e,this.filterPosts(),this.renderResults()})});let t=e.createDiv("search-filter");t.createEl("button",{text:$.t("post_selection_modal.filter_all"),cls:"all"===this.filter?"active":""}).addEventListener("click",async()=>{this.filter="all",await this.loadPosts(),this.renderResults()}),t.createEl("button",{text:$.t("post_selection_modal.filter_published"),cls:"published"===this.filter?"active":""}).addEventListener("click",async()=>{this.filter="published",await this.loadPosts(),this.renderResults()}),t.createEl("button",{text:$.t("post_selection_modal.filter_draft"),cls:"draft"===this.filter?"active":""}).addEventListener("click",async()=>{this.filter="draft",await this.loadPosts(),this.renderResults()}),e.createDiv("search-results").createEl("p",{text:$.t("search_modal.loading")}),await this.loadPosts(),this.renderResults()}async loadPosts(){try{let e="content.halo.run/deleted=false";"published"===this.filter?e="content.halo.run/deleted=false,content.halo.run/published=true":"draft"===this.filter&&(e="content.halo.run/deleted=false,content.halo.run/published=false");let t=await (0,V.requestUrl)({url:`${this.site.url}/apis/uc.api.content.halo.run/v1alpha1/posts?labelSelector=${encodeURIComponent(e)}&size=100`,headers:{Authorization:`Bearer ${this.site.token}`}});this.posts=t.json.items||[],this.filterPosts()}catch(e){new V.Notice($.t("common.error_connection_failed"))}}filterPosts(){if(!this.searchKeyword){this.filteredPosts=this.posts;return}let e=this.searchKeyword.toLowerCase();this.filteredPosts=this.posts.filter(t=>{let n=(t.post.spec.title||"").toLowerCase(),i=(t.post.spec.slug||"").toLowerCase();return n.includes(e)||i.includes(e)})}renderResults(){let{contentEl:e}=this,t=e.querySelector(".search-results");if(t){if(t.empty(),0===this.filteredPosts.length){t.createEl("p",{text:$.t("search_modal.no_results")});return}for(let e of(t.createEl("p",{text:$.t("search_modal.result_count",{count:this.filteredPosts.length}),cls:"result-count"}),this.filteredPosts))this.renderPostItem(e,t)}}renderPostItem(e,t){let n=t.createDiv("search-result-item"),i=n.createDiv("result-header");i.createEl("h3",{text:e.post.spec.title||$.t("post_selection_modal.untitled")}),i.createSpan({text:e.post.spec.publish?$.t("post_selection_modal.status_published"):$.t("post_selection_modal.status_draft"),cls:e.post.spec.publish?"status-published":"status-draft"});let a=n.createDiv("result-meta");a.createEl("span",{text:`Slug: ${e.post.spec.slug}`}),a.createEl("span",{text:` | ${new Date(e.post.metadata.creationTimestamp).toLocaleDateString()}`});let o=n.createDiv("result-actions");o.createEl("button",{text:$.t("search_modal.button_view")}).addEventListener("click",()=>{window.open(`${this.site.url}/archives/${e.post.spec.slug}`,"_blank")}),o.createEl("button",{text:$.t("search_modal.button_export_md")}).addEventListener("click",async()=>{await eB(this.plugin,e.post.metadata.name,e.post.spec.title)}),o.createEl("button",{text:$.t("search_modal.button_export_json")}).addEventListener("click",async()=>{await eJ(this.plugin,e.post.metadata.name,e.post.spec.title)})}onClose(){let{contentEl:e}=this;e.empty()}constructor(e,t){super(app),eT(this,"plugin",void 0),eT(this,"site",void 0),eT(this,"posts",void 0),eT(this,"filteredPosts",void 0),eT(this,"searchKeyword",void 0),eT(this,"filter",void 0),this.plugin=e,this.site=t,this.posts=[],this.filteredPosts=[],this.searchKeyword="",this.filter="all"}}async function eN(e){try{if(0===e.settings.sites.length){new V.Notice($.t("command.pull_post.error_no_sites"));return}let t=e.settings.sites[0];e.settings.sites.length>1&&(t=await ec(e)),eZ(e,t)}catch(e){console.error("[HaloPlugin] Search posts failed:",e),new V.Notice($.t("common.error_connection_failed"))}}function eH(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function eM(e,t,n=-1){return new Promise((i,a)=>{new eQ(e,t||{name:"",url:"",default:!1,token:""},n,(e,t)=>{i({site:e,index:t})}).open()})}class eQ extends V.Modal{onOpen(){let{contentEl:e}=this;(()=>{e.empty(),e.createEl("h2",{text:$.t("site_editing_modal.title")}),new V.Setting(e).setName($.t("site_editing_modal.settings.name.name")).setDesc($.t("site_editing_modal.settings.name.description")).addText(e=>e.setValue(this.currentSite.name).onChange(e=>{this.currentSite.name=e})),new V.Setting(e).setName($.t("site_editing_modal.settings.url.name")).setDesc($.t("site_editing_modal.settings.url.description")).addText(e=>e.setValue(this.currentSite.url).onChange(e=>{this.currentSite.url=e})),new V.Setting(e).setName($.t("site_editing_modal.settings.token.name")).setDesc($.t("site_editing_modal.settings.token.description")).addText(e=>e.setValue(this.currentSite.token).onChange(e=>{this.currentSite.token=e})),new V.Setting(e).setName($.t("site_editing_modal.settings.default.name")).setDesc($.t("site_editing_modal.settings.default.description")).addToggle(e=>e.setValue(this.currentSite.default).onChange(e=>{this.currentSite.default=e})),new V.Setting(e).addButton(e=>{e.setButtonText($.t("site_editing_modal.settings.validate.button")).onClick(()=>{e.setDisabled(!0),e.setButtonText($.t("site_editing_modal.settings.validate.button_validating")),(0,V.requestUrl)({url:`${this.currentSite.url}/apis/api.console.halo.run/v1alpha1/users/-/permissions`,headers:{Authorization:`Bearer ${this.currentSite.token}`}}).then(e=>{new V.Notice(e.json.uiPermissions.includes("uc:posts:manage")?$.t("site_editing_modal.settings.validate.notice_validated"):$.t("site_editing_modal.settings.validate.error_no_permissions"))}).catch(()=>{new V.Notice($.t("common.error_connection_failed"))}).finally(()=>{e.setDisabled(!1),e.setButtonText($.t("site_editing_modal.settings.validate.button"))})})}).addButton(e=>e.setButtonText($.t("site_editing_modal.settings.save.button")).setCta().onClick(()=>{this.onSubmit(this.currentSite,this.index),this.close()}))})()}onClose(){let{contentEl:e}=this;e.empty()}constructor(e,t,n,i){super(app),eH(this,"plugin",void 0),eH(this,"site",void 0),eH(this,"index",void 0),eH(this,"onSubmit",void 0),eH(this,"currentSite",void 0),this.plugin=e,this.site=t,this.index=n,this.onSubmit=i,this.currentSite=Object.assign({},t)}}function eP(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}class eI extends V.Modal{onOpen(){let{contentEl:e}=this,t=()=>{e.empty(),e.createEl("h2",{text:$.t("sites_modal.title")}),this.plugin.settings.sites.forEach((n,i)=>{let a=new V.Setting(e).setName(n.name).setDesc(n.url);!n.default&&a.addButton(e=>e.setButtonText($.t("sites_modal.actions.set_default")).onClick(()=>{for(let e of this.plugin.settings.sites)e.default=!1;n.default=!0,this.plugin.saveSettings(),t()})),a.addButton(e=>e.setButtonText($.t("sites_modal.actions.edit")).onClick(async()=>{let{site:e,index:a}=await eM(this.plugin,n,i);void 0!==a&&a>-1&&(this.plugin.settings.sites[a]=e,await this.plugin.saveSettings(),t())})),a.addExtraButton(e=>e.setIcon("lucide-trash").onClick(()=>{this.plugin.settings.sites.splice(i,1),this.plugin.saveSettings(),t()}))}),new V.Setting(e).addButton(e=>e.setButtonText($.t("sites_modal.actions.add")).onClick(async()=>{let{site:e}=await eM(this.plugin);if(0===this.plugin.settings.sites.length&&(e.default=!0),e.default)for(let e of this.plugin.settings.sites)e.default=!1;this.plugin.settings.sites.push(e),await this.plugin.saveSettings(),t()}))};t()}onClose(){let{contentEl:e}=this;e.empty()}constructor(e){super(app),eP(this,"plugin",void 0),this.plugin=e}}function eG(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}let eR="halo-sync-status";class eO extends V.ItemView{getViewType(){return eR}getDisplayText(){return $.t("sync_panel.title")}async onOpen(){this.render()}loadHistory(){let e=this.plugin.loadData();this.history=(null==e?void 0:e.syncHistory)||[]}saveHistory(){let e=this.plugin.loadData()||{};e.syncHistory=this.history.slice(-50),this.plugin.saveData(e)}addToHistory(e,t,n){this.history.push({id:Date.now().toString(),action:e,title:t,timestamp:Date.now(),success:n}),this.saveHistory()}getPublishedPosts(){let e=[];for(let o of this.plugin.app.vault.getFiles()){var t,n,i,a;if("md"!==o.extension)continue;let s=this.plugin.app.metadataCache.getFileCache(o);if(!(null==s?void 0:null===(n=s.frontmatter)||void 0===n?void 0:null===(t=n.halo)||void 0===t?void 0:t.name))continue;let u=null!==(i=s.frontmatter.halo.publish)&&void 0!==i&&i,r=null!==(a=s.frontmatter.halo.localModified)&&void 0!==a&&a,l="synced";u?r&&(l="local-modified"):l="unpublished";let h=this.extractCategories(s.frontmatter);e.push({file:o,title:s.frontmatter.title||o.basename,slug:s.frontmatter.slug||"",haloName:s.frontmatter.halo.name,haloSite:s.frontmatter.halo.site||"",publishStatus:u,syncStatus:l,categories:h,tags:this.extractTags(s.frontmatter),localModified:o.stat.mtime,remoteModified:s.frontmatter.halo.remoteModified})}return e}extractCategories(e){let t=[];return e.categories&&(Array.isArray(e.categories)?t.push(...e.categories.map(String)):t.push(String(e.categories))),t.length>0?t:["未分类"]}extractTags(e){let t=[];if(e.tags){if(Array.isArray(e.tags))t.push(...e.tags.map(String));else if("string"==typeof e.tags){let n=e.tags.replace(/[\[\]]/g,"").split(",").map(e=>e.trim());t.push(...n.filter(Boolean))}}return t}groupPostsByCategory(e){let t=new Map;for(let n of e){let e=n.categories[0]||"未分类";!t.has(e)&&t.set(e,[]),t.get(e).push(n)}return Array.from(t.entries()).map(([e,t])=>({category:e,posts:t})).sort((e,t)=>"未分类"===e.category?1:"未分类"===t.category?-1:e.category.localeCompare(t.category))}filterPosts(e){let t=e;if(this.searchQuery){let e=this.searchQuery.toLowerCase();t=t.filter(t=>t.title.toLowerCase().includes(e)||t.slug.toLowerCase().includes(e)||t.categories.some(t=>t.toLowerCase().includes(e))||t.tags.some(t=>t.toLowerCase().includes(e)))}switch(this.filterMode){case"synced":return t.filter(e=>"synced"===e.syncStatus);case"pending":return t.filter(e=>"synced"!==e.syncStatus);default:return t}}getStatusIcon(e){switch(e){case"synced":return"\uD83D\uDFE2";case"local-modified":return"\uD83D\uDFE1";case"remote-updated":return"\uD83D\uDD35";case"unpublished":return"⚪"}}getStatusText(e){switch(e){case"synced":return $.t("sync_panel.status_synced");case"local-modified":return $.t("sync_panel.status_local_modified");case"remote-updated":return $.t("sync_panel.status_remote_updated");case"unpublished":return $.t("sync_panel.status_unpublished")}}formatRelativeTime(e){let t=Date.now()-e,n=Math.floor(t/6e4),i=Math.floor(t/36e5),a=Math.floor(t/864e5);return n<1?$.t("sync_panel.time_just_now"):n<60?$.t("sync_panel.time_minutes_ago",{count:n}):i<24?$.t("sync_panel.time_hours_ago",{count:i}):$.t("sync_panel.time_days_ago",{count:a})}async performAction(e,t){let n=this.plugin.settings.sites.find(t=>t.url===e.haloSite);if(!n){new V.Notice($.t("service.error_site_not_match"));return}let{default:i}=await Promise.resolve().then(__webpack_require__.bind(__webpack_require__,"./src/service/index.ts")),a=new i(this.plugin.app,this.plugin.settings,n);try{switch(t){case"update":await a.updatePost(),this.addToHistory("update",e.title,!0),new V.Notice($.t("command.update_post.success"));break;case"publish":await a.publishPost(),this.addToHistory("publish",e.title,!0),new V.Notice($.t("service.notice_publish_success"));break;case"pull":await a.pullPost(e.haloName),this.addToHistory("pull",e.title,!0)}this.render()}catch(n){this.addToHistory(t,e.title,!1),new V.Notice($.t("service.error_publish_failed"))}}renderPostDetail(e){let t=document.createElement("div");t.className="sync-detail-modal",t.style.cssText=` position: fixed; top: 0; left: 0; right: 0; bottom: 0; background: rgba(0,0,0,0.6); display: flex; align-items: center; justify-content: center; z-index: 1000; @@ -86,7 +86,7 @@ ${u}`,l=`${n}.md`,h=await e.app.vault.create(l,r);e.app.workspace.getLeaf().open `,a.textContent=`${this.getStatusIcon(e.syncStatus)} ${this.getStatusText(e.syncStatus)}`,n.appendChild(a);let o=document.createElement("div");o.style.cssText="display: flex; flex-direction: column; gap: 8px; margin-bottom: 16px;";let s=(e,t)=>{let n=document.createElement("div");n.style.cssText="display: flex; justify-content: space-between;",n.innerHTML=`${e}${t}`,o.appendChild(n)};if(s($.t("sync_panel.detail_title_label"),e.title),s("Slug",e.slug||"-"),s($.t("sync_panel.detail_category"),e.categories.join(" > ")),s($.t("sync_panel.detail_tags"),e.tags.length>0?e.tags.map(e=>`#${e}`).join(" "):"-"),n.appendChild(o),e.localModified){let t=document.createElement("div");t.style.cssText="background: var(--background-secondary); padding: 12px; border-radius: 8px; margin-bottom: 12px;",t.innerHTML=`
${$.t("sync_panel.detail_local_version")}
${$.t("sync_panel.detail_modified")}: ${this.formatRelativeTime(e.localModified)}
- `,n.appendChild(t)}let u=document.createElement("button");u.textContent=$.t("common.button_close"),u.style.cssText="width: 100%; margin-top: 16px; padding: 10px;",u.addEventListener("click",()=>{t.remove(),this.render()}),n.appendChild(u),t.addEventListener("click",e=>{e.target===t&&(t.remove(),this.render())}),document.body.appendChild(t)}render(){let e=this.containerEl;e.empty(),this.selectedPosts.clear();let t=e.createDiv("sync-header");t.style.cssText="display: flex; justify-content: space-between; align-items: center; padding: 16px; border-bottom: 1px solid var(--border-color);";let n=t.createDiv("sync-title-section");n.style.cssText="display: flex; align-items: center; gap: 8px;",n.createSpan("sync-status-dot").style.cssText="width: 10px; height: 10px; border-radius: 50%; background: var(--color-green);",n.createEl("h2",{text:$.t("sync_panel.title"),cls:"sync-view-title"});let i=t.createDiv("sync-actions");i.style.cssText="display: flex; gap: 8px;";let a=i.createEl("button",{text:"⚙️",cls:"sync-icon-btn",attr:{title:$.t("sync_panel.button_settings")}});a.style.cssText="border: none; background: transparent; cursor: pointer; font-size: 16px; padding: 4px;",a.addEventListener("click",()=>{this.app.settings});let o=i.createEl("button",{text:"\uD83D\uDCCA",cls:"sync-icon-btn",attr:{title:$.t("sync_panel.button_history")}});o.style.cssText="border: none; background: transparent; cursor: pointer; font-size: 16px; padding: 4px;",o.addEventListener("click",()=>this.showHistory());let s=e.createDiv("sync-search-bar");s.style.cssText="padding: 12px 16px; border-bottom: 1px solid var(--border-color);";let u=s.createEl("input",{type:"text",cls:"sync-search-input"});u.setAttribute("placeholder",$.t("sync_panel.search_placeholder")),u.style.cssText=` + `,n.appendChild(t)}let u=document.createElement("button");u.textContent=$.t("common.button_close"),u.style.cssText="width: 100%; margin-top: 16px; padding: 10px;",u.addEventListener("click",()=>{t.remove(),this.render()}),n.appendChild(u),t.addEventListener("click",e=>{e.target===t&&(t.remove(),this.render())}),document.body.appendChild(t)}render(){let e=this.containerEl;e.empty(),this.selectedPosts.clear();let t=e.createDiv("sync-header");t.style.cssText="display: flex; justify-content: space-between; align-items: center; padding: 16px; border-bottom: 1px solid var(--border-color);";let n=t.createDiv("sync-title-section");n.style.cssText="display: flex; align-items: center; gap: 8px;",n.createSpan("sync-status-dot").style.cssText="width: 10px; height: 10px; border-radius: 50%; background: var(--color-green);",n.createEl("h2",{text:$.t("sync_panel.title"),cls:"sync-view-title"});let i=t.createDiv("sync-actions");i.style.cssText="display: flex; gap: 8px;";let a=i.createEl("button",{text:"⚙️",cls:"sync-icon-btn",attr:{title:$.t("sync_panel.button_settings")}});a.style.cssText="border: none; background: transparent; cursor: pointer; font-size: 16px; padding: 4px;",a.addEventListener("click",()=>{new eI(this.plugin).open()});let o=i.createEl("button",{text:"\uD83D\uDCCA",cls:"sync-icon-btn",attr:{title:$.t("sync_panel.button_history")}});o.style.cssText="border: none; background: transparent; cursor: pointer; font-size: 16px; padding: 4px;",o.addEventListener("click",()=>this.showHistory());let s=e.createDiv("sync-search-bar");s.style.cssText="padding: 12px 16px; border-bottom: 1px solid var(--border-color);";let u=s.createEl("input",{type:"text",cls:"sync-search-input"});u.setAttribute("placeholder",$.t("sync_panel.search_placeholder")),u.style.cssText=` width: 100%; padding: 8px 12px; border: 1px solid var(--border-color); border-radius: 8px; background: var(--background-secondary); `,u.value=this.searchQuery,u.addEventListener("input",()=>{this.searchQuery=u.value,this.render()});let r=e.createDiv("sync-filter-tabs");for(let e of(r.style.cssText="display: flex; padding: 0 16px; gap: 8px; border-bottom: 1px solid var(--border-color);",[{key:"all",label:`📁 ${$.t("sync_panel.filter_all")}`},{key:"synced",label:`✅ ${$.t("sync_panel.filter_synced")}`},{key:"pending",label:`🔄 ${$.t("sync_panel.filter_pending")}`}])){let t=r.createEl("button");t.textContent=e.label,t.style.cssText=` @@ -130,4 +130,4 @@ ${u}`,l=`${n}.md`,h=await e.app.vault.create(l,r);e.app.workspace.getLeaf().open `;let n=t.createElement("h3");if(n.textContent=$.t("sync_history.title"),n.style.cssText="margin: 0 0 16px 0;",this.history.length>0){let e=document.createElement("div");e.style.cssText="font-size: 12px; color: var(--text-muted); margin-bottom: 16px;";let n=this.history.filter(e=>e.success).length;e.textContent=$.t("sync_history.stats",{total:this.history.length,success:n}),t.appendChild(e)}let i=t.createElement("button");if(i.textContent=$.t("common.button_close"),i.style.cssText="margin-bottom: 16px;",i.addEventListener("click",()=>e.remove()),0===this.history.length){let e=t.createElement("p");e.textContent=$.t("sync_history.empty"),e.className="history-empty"}else{let e=t.createElement("div");for(let t of(e.className="sync-history-list",[...this.history].reverse())){let n=document.createElement("div");n.style.cssText=` display: flex; justify-content: space-between; align-items: center; padding: 10px; border-bottom: 1px solid var(--border-color); - `;let i=document.createElement("div");i.style.cssText="display: flex; align-items: center; gap: 8px;",i.innerHTML=`${t.success?"✅":"❌"}${$.t(`sync_history.action_${t.action}`)}: ${t.title}`;let a=document.createElement("span");a.style.cssText="font-size: 11px; color: var(--text-muted);",a.textContent=new Date(t.timestamp).toLocaleString(),n.appendChild(i),n.appendChild(a),e.appendChild(n)}t.appendChild(e)}let a=t.createElement("button");a.textContent=$.t("sync_panel.button_clear_history"),a.className="history-clear-btn",a.style.cssText="width: 100%; margin-top: 16px;",a.addEventListener("click",()=>{this.clearHistory(),e.remove()}),e.addEventListener("click",t=>{t.target===e&&e.remove()}),t.insertBefore(i,t.firstChild),t.appendChild(a),e.appendChild(t),document.body.appendChild(e)}clearHistory(){confirm($.t("sync_history.confirm_clear"))&&(this.history=[],this.saveHistory(),this.render(),new V.Notice($.t("sync_history.notice_cleared")))}constructor(e,t){super(e),eH(this,"plugin",void 0),eH(this,"history",[]),eH(this,"selectedPosts",new Set),eH(this,"searchQuery",""),eH(this,"filterMode","all"),this.plugin=t,this.loadHistory()}}function eP(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function eI(e,t,n=-1){return new Promise((i,a)=>{new eG(e,t||{name:"",url:"",default:!1,token:""},n,(e,t)=>{i({site:e,index:t})}).open()})}class eG extends V.Modal{onOpen(){let{contentEl:e}=this;(()=>{e.empty(),e.createEl("h2",{text:$.t("site_editing_modal.title")}),new V.Setting(e).setName($.t("site_editing_modal.settings.name.name")).setDesc($.t("site_editing_modal.settings.name.description")).addText(e=>e.setValue(this.currentSite.name).onChange(e=>{this.currentSite.name=e})),new V.Setting(e).setName($.t("site_editing_modal.settings.url.name")).setDesc($.t("site_editing_modal.settings.url.description")).addText(e=>e.setValue(this.currentSite.url).onChange(e=>{this.currentSite.url=e})),new V.Setting(e).setName($.t("site_editing_modal.settings.token.name")).setDesc($.t("site_editing_modal.settings.token.description")).addText(e=>e.setValue(this.currentSite.token).onChange(e=>{this.currentSite.token=e})),new V.Setting(e).setName($.t("site_editing_modal.settings.default.name")).setDesc($.t("site_editing_modal.settings.default.description")).addToggle(e=>e.setValue(this.currentSite.default).onChange(e=>{this.currentSite.default=e})),new V.Setting(e).addButton(e=>{e.setButtonText($.t("site_editing_modal.settings.validate.button")).onClick(()=>{e.setDisabled(!0),e.setButtonText($.t("site_editing_modal.settings.validate.button_validating")),(0,V.requestUrl)({url:`${this.currentSite.url}/apis/api.console.halo.run/v1alpha1/users/-/permissions`,headers:{Authorization:`Bearer ${this.currentSite.token}`}}).then(e=>{new V.Notice(e.json.uiPermissions.includes("uc:posts:manage")?$.t("site_editing_modal.settings.validate.notice_validated"):$.t("site_editing_modal.settings.validate.error_no_permissions"))}).catch(()=>{new V.Notice($.t("common.error_connection_failed"))}).finally(()=>{e.setDisabled(!1),e.setButtonText($.t("site_editing_modal.settings.validate.button"))})})}).addButton(e=>e.setButtonText($.t("site_editing_modal.settings.save.button")).setCta().onClick(()=>{this.onSubmit(this.currentSite,this.index),this.close()}))})()}onClose(){let{contentEl:e}=this;e.empty()}constructor(e,t,n,i){super(app),eP(this,"plugin",void 0),eP(this,"site",void 0),eP(this,"index",void 0),eP(this,"onSubmit",void 0),eP(this,"currentSite",void 0),this.plugin=e,this.site=t,this.index=n,this.onSubmit=i,this.currentSite=Object.assign({},t)}}function eR(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}class eO extends V.Modal{onOpen(){let{contentEl:e}=this,t=()=>{e.empty(),e.createEl("h2",{text:$.t("sites_modal.title")}),this.plugin.settings.sites.forEach((n,i)=>{let a=new V.Setting(e).setName(n.name).setDesc(n.url);!n.default&&a.addButton(e=>e.setButtonText($.t("sites_modal.actions.set_default")).onClick(()=>{for(let e of this.plugin.settings.sites)e.default=!1;n.default=!0,this.plugin.saveSettings(),t()})),a.addButton(e=>e.setButtonText($.t("sites_modal.actions.edit")).onClick(async()=>{let{site:e,index:a}=await eI(this.plugin,n,i);void 0!==a&&a>-1&&(this.plugin.settings.sites[a]=e,await this.plugin.saveSettings(),t())})),a.addExtraButton(e=>e.setIcon("lucide-trash").onClick(()=>{this.plugin.settings.sites.splice(i,1),this.plugin.saveSettings(),t()}))}),new V.Setting(e).addButton(e=>e.setButtonText($.t("sites_modal.actions.add")).onClick(async()=>{let{site:e}=await eI(this.plugin);if(0===this.plugin.settings.sites.length&&(e.default=!0),e.default)for(let e of this.plugin.settings.sites)e.default=!1;this.plugin.settings.sites.push(e),await this.plugin.saveSettings(),t()}))};t()}onClose(){let{contentEl:e}=this;e.empty()}constructor(e){super(app),eR(this,"plugin",void 0),this.plugin=e}}function eK(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}let ez={sites:[],publishByDefault:!1,imageUpload:{enabled:!0,uploadPath:"",preserveOriginal:!1}};class eW extends V.PluginSettingTab{display(){let{containerEl:e}=this;e.empty(),new V.Setting(e).setName($.t("settings.site.name")).setDesc($.t("settings.site.description")).addButton(e=>e.setButtonText($.t("settings.site.actions.open")).onClick(()=>{new eO(this.plugin).open()})),new V.Setting(e).setName($.t("settings.publishByDefault.name")).setDesc($.t("settings.publishByDefault.description")).addToggle(e=>{e.setValue(this.plugin.settings.publishByDefault).onChange(e=>{this.plugin.settings.publishByDefault=e,this.plugin.saveSettings()})}),new V.Setting(e).setName($.t("settings.imageUpload.enabled.name")).setDesc($.t("settings.imageUpload.enabled.description")).addToggle(e=>{e.setValue(this.plugin.settings.imageUpload.enabled).onChange(e=>{this.plugin.settings.imageUpload.enabled=e,this.plugin.saveSettings()})}),new V.Setting(e).setName($.t("settings.imageUpload.uploadPath.name")).setDesc($.t("settings.imageUpload.uploadPath.description")).addText(e=>{e.setValue(this.plugin.settings.imageUpload.uploadPath).onChange(e=>{this.plugin.settings.imageUpload.uploadPath=e,this.plugin.saveSettings()})}),new V.Setting(e).setName($.t("settings.imageUpload.preserveOriginal.name")).setDesc($.t("settings.imageUpload.preserveOriginal.description")).addToggle(e=>{e.setValue(this.plugin.settings.imageUpload.preserveOriginal).onChange(e=>{this.plugin.settings.imageUpload.preserveOriginal=e,this.plugin.saveSettings()})})}constructor(e){super(app,e),eK(this,"plugin",void 0),this.plugin=e}}function eU(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}class eq extends V.Plugin{async onload(){console.log("loading obsidian-halo plugin"),await $.init({lng:V.moment.locale(),fallbackLng:"en",resources:eo,returnNull:!1}),await this.loadSettings(),eu(),this.addRibbonIcon("halo-logo",$.t("ribbon_icon.publish"),async e=>{await this.publishCommand()}),this.addRibbonIcon("sync-icon",$.t("ribbon_icon.sync_status"),async e=>{await this.openSyncStatusPanel()}),this.addCommand({id:"publish",name:$.t("command.publish.name"),callback:async()=>{await this.publishCommand()}}),this.addCommand({id:"publish-with-defaults",name:$.t("command.publish_with_defaults.name"),callback:async()=>{let e=this.settings.sites.find(e=>e.default);if(!e){new V.Notice($.t("command.publish_with_defaults.error_no_default_site"));return}let t=new eb.default(this.app,this.settings,e);await t.publishPost()}}),this.addCommand({id:"update-post",name:$.t("command.update_post.name"),editorCallback:async()=>{var e,t;let{activeEditor:n}=this.app.workspace;if(!n||!n.file)return;let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(!(null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.site)){new V.Notice($.t("command.update_post.error_not_published"));return}let a=this.settings.sites.find(e=>{var t;return e.url===(null===(t=i.halo)||void 0===t?void 0:t.site)});if(!a){new V.Notice($.t("command.update_post.error_no_matched_site"));return}let o=new eb.default(this.app,this.settings,a);await o.updatePost(),new V.Notice($.t("command.update_post.success"))}}),this.addCommand({id:"pull-post",name:$.t("command.pull_post.name"),callback:async()=>{if(0===this.settings.sites.length){new V.Notice($.t("command.pull_post.error_no_sites"));return}let e=this.settings.sites[0];this.settings.sites.length>1&&(e=await ec(this));let t=await el(this,e),n=new eb.default(this.app,this.settings,e);await n.pullPost(t.post.metadata.name)}}),this.addCommand({id:"import-markdown",name:$.t("command.import_markdown.name"),callback:async()=>{await ef(this)}}),this.addCommand({id:"delete-post",name:$.t("command.delete_post.name"),editorCallback:async()=>{await eC(this)}}),this.addCommand({id:"manage-tags",name:$.t("command.manage_tags.name"),callback:async()=>{await eF(this)}}),this.addCommand({id:"manage-categories",name:$.t("command.manage_categories.name"),callback:async()=>{await eY(this)}}),this.addCommand({id:"search-posts",name:$.t("command.search_posts.name"),callback:async()=>{await eN(this)}}),this.addCommand({id:"export-post-as-markdown",name:$.t("command.export_markdown.name"),editorCallback:async()=>{var e,t;let{activeEditor:n}=this.app.workspace;if(!n||!n.file)return;let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(!(null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.name)){new V.Notice($.t("command.export_markdown.error_not_published"));return}await eB(this,i.halo.name,i.title||n.file.basename)}}),this.addCommand({id:"export-post-as-json",name:$.t("command.export_json.name"),editorCallback:async()=>{var e,t;let{activeEditor:n}=this.app.workspace;if(!n||!n.file)return;let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(!(null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.name)){new V.Notice($.t("command.export_json.error_not_published"));return}await eJ(this,i.halo.name,i.title||n.file.basename)}}),this.addCommand({id:"open-sync-status-panel",name:$.t("command.open_sync_panel.name"),callback:async()=>{await this.openSyncStatusPanel()}}),this.addSettingTab(new eW(this)),this.registerView(eM,e=>new eQ(e,this))}async openSyncStatusPanel(){let e=this.app.workspace.getRightLeaf(!1);e&&await e.setViewState({type:eM})}onunload(){}async loadSettings(){this.settings=Object.assign({},ez,await this.loadData())}async saveSettings(){await this.saveData(this.settings)}async publishCommand(){var e,t;console.log("[HaloPlugin] 执行发布命令");let{activeEditor:n}=this.app.workspace;if(console.log(`[HaloPlugin] activeEditor: ${n?"存在":"不存在"}`),!n||!n.file){console.log("[HaloPlugin] 没有打开的编辑器，退出");return}console.log(`[HaloPlugin] 当前文件: ${n.file.path}`);let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(console.log(`[HaloPlugin] frontmatter: ${JSON.stringify(i)}`),null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.site){console.log(`[HaloPlugin] 检测到已发布的文章，站点: ${i.halo.site}`);let e=this.settings.sites.find(e=>e.url===i.halo.site);if(!e){console.log("[HaloPlugin] 未找到匹配的站点配置"),new V.Notice($.t("command.publish.error_no_matched_site"));return}console.log(`[HaloPlugin] 找到站点: ${e.name}, URL: ${e.url}`);let t=new eb.default(this.app,this.settings,e);await t.publishPost();return}console.log("[HaloPlugin] 文章未发布过，需要选择站点");let a=await ec(this);console.log(`[HaloPlugin] 选择站点: ${a.name}, URL: ${a.url}`);let o=new eb.default(this.app,this.settings,a);await o.publishPost()}constructor(...e){super(...e),eU(this,"settings",void 0)}}})();var __webpack_export_target__=exports;for(var __webpack_i__ in __webpack_exports__)__webpack_export_target__[__webpack_i__]=__webpack_exports__[__webpack_i__];__webpack_exports__.__esModule&&Object.defineProperty(__webpack_export_target__,"__esModule",{value:!0}); \ No newline at end of file + `;let i=document.createElement("div");i.style.cssText="display: flex; align-items: center; gap: 8px;",i.innerHTML=`${t.success?"✅":"❌"}${$.t(`sync_history.action_${t.action}`)}: ${t.title}`;let a=document.createElement("span");a.style.cssText="font-size: 11px; color: var(--text-muted);",a.textContent=new Date(t.timestamp).toLocaleString(),n.appendChild(i),n.appendChild(a),e.appendChild(n)}t.appendChild(e)}let a=t.createElement("button");a.textContent=$.t("sync_panel.button_clear_history"),a.className="history-clear-btn",a.style.cssText="width: 100%; margin-top: 16px;",a.addEventListener("click",()=>{this.clearHistory(),e.remove()}),e.addEventListener("click",t=>{t.target===e&&e.remove()}),t.insertBefore(i,t.firstChild),t.appendChild(a),e.appendChild(t),document.body.appendChild(e)}clearHistory(){confirm($.t("sync_history.confirm_clear"))&&(this.history=[],this.saveHistory(),this.render(),new V.Notice($.t("sync_history.notice_cleared")))}constructor(e,t){super(e),eG(this,"plugin",void 0),eG(this,"history",[]),eG(this,"selectedPosts",new Set),eG(this,"searchQuery",""),eG(this,"filterMode","all"),this.plugin=t,this.loadHistory()}}function eK(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}let ez={sites:[],publishByDefault:!1,imageUpload:{enabled:!0,uploadPath:"",preserveOriginal:!1}};class eW extends V.PluginSettingTab{display(){let{containerEl:e}=this;e.empty(),new V.Setting(e).setName($.t("settings.site.name")).setDesc($.t("settings.site.description")).addButton(e=>e.setButtonText($.t("settings.site.actions.open")).onClick(()=>{new eI(this.plugin).open()})),new V.Setting(e).setName($.t("settings.publishByDefault.name")).setDesc($.t("settings.publishByDefault.description")).addToggle(e=>{e.setValue(this.plugin.settings.publishByDefault).onChange(e=>{this.plugin.settings.publishByDefault=e,this.plugin.saveSettings()})}),new V.Setting(e).setName($.t("settings.imageUpload.enabled.name")).setDesc($.t("settings.imageUpload.enabled.description")).addToggle(e=>{e.setValue(this.plugin.settings.imageUpload.enabled).onChange(e=>{this.plugin.settings.imageUpload.enabled=e,this.plugin.saveSettings()})}),new V.Setting(e).setName($.t("settings.imageUpload.uploadPath.name")).setDesc($.t("settings.imageUpload.uploadPath.description")).addText(e=>{e.setValue(this.plugin.settings.imageUpload.uploadPath).onChange(e=>{this.plugin.settings.imageUpload.uploadPath=e,this.plugin.saveSettings()})}),new V.Setting(e).setName($.t("settings.imageUpload.preserveOriginal.name")).setDesc($.t("settings.imageUpload.preserveOriginal.description")).addToggle(e=>{e.setValue(this.plugin.settings.imageUpload.preserveOriginal).onChange(e=>{this.plugin.settings.imageUpload.preserveOriginal=e,this.plugin.saveSettings()})})}constructor(e){super(app,e),eK(this,"plugin",void 0),this.plugin=e}}function eU(e,t,n){return t in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}class eq extends V.Plugin{async onload(){console.log("loading obsidian-halo plugin"),await $.init({lng:V.moment.locale(),fallbackLng:"en",resources:eo,returnNull:!1}),await this.loadSettings(),eu(),this.addRibbonIcon("halo-logo",$.t("ribbon_icon.publish"),async e=>{await this.publishCommand()}),this.addRibbonIcon("sync-icon",$.t("ribbon_icon.sync_status"),async e=>{await this.openSyncStatusPanel()}),this.addCommand({id:"publish",name:$.t("command.publish.name"),callback:async()=>{await this.publishCommand()}}),this.addCommand({id:"publish-with-defaults",name:$.t("command.publish_with_defaults.name"),callback:async()=>{let e=this.settings.sites.find(e=>e.default);if(!e){new V.Notice($.t("command.publish_with_defaults.error_no_default_site"));return}let t=new eb.default(this.app,this.settings,e);await t.publishPost()}}),this.addCommand({id:"update-post",name:$.t("command.update_post.name"),editorCallback:async()=>{var e,t;let{activeEditor:n}=this.app.workspace;if(!n||!n.file)return;let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(!(null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.site)){new V.Notice($.t("command.update_post.error_not_published"));return}let a=this.settings.sites.find(e=>{var t;return e.url===(null===(t=i.halo)||void 0===t?void 0:t.site)});if(!a){new V.Notice($.t("command.update_post.error_no_matched_site"));return}let o=new eb.default(this.app,this.settings,a);await o.updatePost(),new V.Notice($.t("command.update_post.success"))}}),this.addCommand({id:"pull-post",name:$.t("command.pull_post.name"),callback:async()=>{if(0===this.settings.sites.length){new V.Notice($.t("command.pull_post.error_no_sites"));return}let e=this.settings.sites[0];this.settings.sites.length>1&&(e=await ec(this));let t=await el(this,e),n=new eb.default(this.app,this.settings,e);await n.pullPost(t.post.metadata.name)}}),this.addCommand({id:"import-markdown",name:$.t("command.import_markdown.name"),callback:async()=>{await ef(this)}}),this.addCommand({id:"delete-post",name:$.t("command.delete_post.name"),editorCallback:async()=>{await eC(this)}}),this.addCommand({id:"manage-tags",name:$.t("command.manage_tags.name"),callback:async()=>{await eF(this)}}),this.addCommand({id:"manage-categories",name:$.t("command.manage_categories.name"),callback:async()=>{await eY(this)}}),this.addCommand({id:"search-posts",name:$.t("command.search_posts.name"),callback:async()=>{await eN(this)}}),this.addCommand({id:"export-post-as-markdown",name:$.t("command.export_markdown.name"),editorCallback:async()=>{var e,t;let{activeEditor:n}=this.app.workspace;if(!n||!n.file)return;let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(!(null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.name)){new V.Notice($.t("command.export_markdown.error_not_published"));return}await eB(this,i.halo.name,i.title||n.file.basename)}}),this.addCommand({id:"export-post-as-json",name:$.t("command.export_json.name"),editorCallback:async()=>{var e,t;let{activeEditor:n}=this.app.workspace;if(!n||!n.file)return;let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(!(null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.name)){new V.Notice($.t("command.export_json.error_not_published"));return}await eJ(this,i.halo.name,i.title||n.file.basename)}}),this.addCommand({id:"open-sync-status-panel",name:$.t("command.open_sync_panel.name"),callback:async()=>{await this.openSyncStatusPanel()}}),this.addSettingTab(new eW(this)),this.registerView(eR,e=>new eO(e,this))}async openSyncStatusPanel(){let e=this.app.workspace.getRightLeaf(!1);e&&await e.setViewState({type:eR})}onunload(){}async loadSettings(){this.settings=Object.assign({},ez,await this.loadData())}async saveSettings(){await this.saveData(this.settings)}async publishCommand(){var e,t;console.log("[HaloPlugin] 执行发布命令");let{activeEditor:n}=this.app.workspace;if(console.log(`[HaloPlugin] activeEditor: ${n?"存在":"不存在"}`),!n||!n.file){console.log("[HaloPlugin] 没有打开的编辑器，退出");return}console.log(`[HaloPlugin] 当前文件: ${n.file.path}`);let i=null===(e=this.app.metadataCache.getFileCache(n.file))||void 0===e?void 0:e.frontmatter;if(console.log(`[HaloPlugin] frontmatter: ${JSON.stringify(i)}`),null==i?void 0:null===(t=i.halo)||void 0===t?void 0:t.site){console.log(`[HaloPlugin] 检测到已发布的文章，站点: ${i.halo.site}`);let e=this.settings.sites.find(e=>e.url===i.halo.site);if(!e){console.log("[HaloPlugin] 未找到匹配的站点配置"),new V.Notice($.t("command.publish.error_no_matched_site"));return}console.log(`[HaloPlugin] 找到站点: ${e.name}, URL: ${e.url}`);let t=new eb.default(this.app,this.settings,e);await t.publishPost();return}console.log("[HaloPlugin] 文章未发布过，需要选择站点");let a=await ec(this);console.log(`[HaloPlugin] 选择站点: ${a.name}, URL: ${a.url}`);let o=new eb.default(this.app,this.settings,a);await o.publishPost()}constructor(...e){super(...e),eU(this,"settings",void 0)}}})();var __webpack_export_target__=exports;for(var __webpack_i__ in __webpack_exports__)__webpack_export_target__[__webpack_i__]=__webpack_exports__[__webpack_i__];__webpack_exports__.__esModule&&Object.defineProperty(__webpack_export_target__,"__esModule",{value:!0}); \ No newline at end of file diff --git a/.obsidian/workspace.json b/.obsidian/workspace.json index 07a00e5..25d9f51 100644 --- a/.obsidian/workspace.json +++ b/.obsidian/workspace.json @@ -225,7 +225,7 @@ "halo:发布当前文档到 Halo": false } }, - "active": "1e741b4d78845bd1", + "active": "e7a7b303c61786dc", "lastOpenFiles": [ "obsidian-halo/docs/usage-guide.md", "博客/学术与效率/AI助你轻松上手LaTeX论文写作.md", diff --git a/obsidian-halo/src/views/sync-status-view.ts b/obsidian-halo/src/views/sync-status-view.ts index 5c639bb..ec5f700 100644 --- a/obsidian-halo/src/views/sync-status-view.ts +++ b/obsidian-halo/src/views/sync-status-view.ts @@ -1,6 +1,7 @@ import i18next from "i18next"; import { ItemView, Notice, WorkspaceLeaf, TFile } from "obsidian"; import type HaloPlugin from "../main"; +import { HaloSitesModal } from "../sites-modal"; export const SYNC_STATUS_VIEW_TYPE = "halo-sync-status"; @@ -371,7 +372,7 @@ export class SyncStatusView extends ItemView { }); settingsBtn.style.cssText = "border: none; background: transparent; cursor: pointer; font-size: 16px; padding: 4px;"; settingsBtn.addEventListener("click", () => { - (this.app as unknown as { settings: unknown }).settings; + new HaloSitesModal(this.plugin).open(); }); const historyBtn = actions.createEl("button", { diff --git a/temp-agent-os-v2.md b/temp-agent-os-v2.md new file mode 100644 index 0000000..b1bd336 --- /dev/null +++ b/temp-agent-os-v2.md @@ -0,0 +1,1035 @@ +# 学习 Agent，越学越像在重新理解操作系统 + +## 引言 + +2024年，当我第一次深入研究 Agent 框架时，产生了一个奇怪的感觉：**这不就是重新发明操作系统吗？** + +进程、线程、系统调用、内存管理、文件系统、设备驱动……这些在大学操作系统课程里让我头疼不已的概念，在 Agent 世界里全都以另一种面貌出现了。只不过是换了层皮——从 CPU 和内存，变成了 Token 和推理时间。 + +花了半年时间，终于把这条暗线理清楚了。今天这篇文章，就是把我看到的、想到的、踩过的坑，全都记录下来。希望你读完之后，能和我有同样的感受：**"原来如此！"** + +--- + +## 壹、从一个痛点说起 + +先问个问题：你有没有这种感觉—— + +学 Agent 的时候，总有一堆新概念要记：ReAct、CoT、ToV、Plan-and-Execute、MRKL、Harness、Orchestrator、Sub-Agent、Context Window、Function Calling…… + +学完一遍，脑子里全是碎片。 + +但有一天，我突然发现：这些概念我都见过。 + +不是在 AI 论文里，而是在**操作系统教科书**里。 + +进程隔离 = Agent 隔离 +系统调用 = Tool Use / Function Calling +虚拟内存分页 = Context Compression +文件系统挂载 = RAG +进程调度器 = Orchestrator +信号量/锁 = Agent 之间的同步机制 + +**操作系统花了几十年解决的问题，Agent 时代正在用同样的思路重新解决一遍。** + +这不是巧合。这是历史在押韵。 + +--- + +## 贰、进程与线程 → Sub-Agent + +### 2.1 操作系统里的进程和线程 + +在操作系统里，**进程（Process）是资源分配的基本单位**，**线程（Thread）是 CPU 调度的基本单位**。 + +这意味着： + +- 每个进程有自己独立的地址空间（内存）、文件句柄、系统资源 +- 同一进程里的线程共享这些资源，但各自有独立的栈和寄存器 +- 进程间通信（IPC）需要显式的机制：管道、消息队列、共享内存、Socket…… +- 线程间通信相对简单，因为共享内存——但也带来了**竞争条件（Race Condition）**的风险 + +这段话看起来枯燥，但让我举个例子你就明白了。 + +**场景**：一个 Web 服务器（进程），处理多个请求（线程）。 + +``` +进程（Web 服务器） +├── 线程1：处理用户A的请求 +├── 线程2：处理用户B的请求 +├── 线程3：处理用户C的请求 +└── ...（更多线程） + │ + ├── 共享资源：数据库连接池、缓存 + ├── 独立资源：每个线程自己的栈、局部变量 + └── 潜在问题：多个线程同时修改同一个变量？ +``` + +这就是经典的**并发问题**。如果线程1和线程2同时往数据库写入，而数据库连接池只有5个连接——两个线程抢同一个连接，就会出问题。 + +### 2.2 Agent 世界里的进程和线程 + +把上面这个场景映射到 Agent 世界： + +- **进程 ≈ 独立的 Agent 实例**（或者一个 Agent 系统） +- **线程 ≈ Sub-Agent / Worker** + +```python +# 操作系统视角 +class Process: + def __init__(self): + self.memory = Memory() # 独立地址空间 + self.files = FileHandles() + self.threads = [] + +# Agent 视角 +class Agent: + def __init__(self, model, tools): + self.memory = Memory() # Agent 的"内存" + self.context = [] # Agent 的"上下文" + self.sub_agents = [] # Sub-Agent 们 +``` + +当我们在设计多 Agent 系统时，几乎立刻遇到了和操作系统一样的问题： + +**问题1：谁能访问谁的状态？** + +如果 Agent A 在处理用户查询，Agent B 在做代码执行，它们能共享同一个 Memory 吗？ + +- 共享 → 效率高，但有数据竞争风险 +- 隔离 → 安全，但信息传递成本高 + +**问题2：共享上下文带来竞争条件** + +``` +时间线： +T1: Agent A 读取 shared_memory["result"] = None +T2: Agent A 开始计算 +T3: Agent B 读取 shared_memory["result"] = None （还是空的！） +T4: Agent A 计算完成，写入 shared_memory["result"] = "答案A" +T5: Agent B 计算完成，写入 shared_memory["result"] = "答案B" （覆盖了！） +``` + +这就是经典的 **ABA 问题**——Agent B 读到的是过期的数据。 + +**问题3：死锁** + +``` +场景： +- Agent A 等 Agent B 的结果 +- Agent B 等 Agent A 的结果 +→ 系统卡死 +``` + +这些问题，操作系统花了几十年才解决。Agent 时代正在用同样的思路重新应对。 + +### 2.3 解决方案：操作系统用过的那些招 + +**方案一：消息传递（Message Passing）** + +操作系统中，进程之间通过**消息队列**通信，不共享内存： + +```python +# 操作系统：进程间消息传递 +class MessageQueue: + def send(self, pid, message): + self.queue[pid].append(message) + + def receive(self, pid): + return self.queue[pid].pop(0) + +# Agent 世界：Agent 间消息传递 +class AgentMessageBus: + def send(self, from_agent, to_agent, message): + self.queue[to_agent].append({ + "from": from_agent, + "content": message, + "timestamp": time.time() + }) + + def receive(self, agent_id): + return self.queue[agent_id].pop(0) +``` + +**方案二：Actor 模型** + +这是分布式系统里很经典的模型，和 Agent 设计高度吻合： + +- 每个 Actor（Agent）有独立的"邮箱" +- Actor 之间不共享状态，通过消息通信 +- 消息是异步的，有 mailbox 缓冲 + +``` +Actor A ──消息──→ Actor B 的 Mailbox + ↑ │ + └──── 响应消息 ───────┘ +``` + +**方案三：锁和信号量** + +如果必须共享状态，就需要同步机制： + +```python +import asyncio + +class SharedContext: + def __init__(self): + self._lock = asyncio.Lock() + self._data = {} + + async def read(self, key): + async with self._lock: + return self._data.get(key) + + async def write(self, key, value): + async with self._lock: + self._data[key] = value +``` + +这和操作系统的**读写锁（Read-Write Lock）**完全是一个思路。 + +### 2.4 实战经验 + +我曾经在做一个多 Agent 协作系统时踩过坑： + +**场景**：一个 Researcher Agent 负责搜索信息，一个 Writer Agent 负责写文章，一个 Editor Agent 负责审核。 + +**问题**：三个 Agent 共享一个 `research_notes` 变量，Editor 在 Writer 还没写完时就读取了。 + +**解决**：参考操作系统的**生产者-消费者模式**，引入消息队列和状态机： + +``` +状态机： +WRITING → EDITING → APPROVED + ↑ + (等待 Writer 完成) +``` + +--- + +## 叁、系统调用 → Tool Use + +### 3.1 操作系统里的系统调用 + +这是最经典、最核心的类比。 + +在操作系统里，**用户程序不能直接访问硬件**。你写的代码运行在"用户态"，硬件操作必须通过"系统调用"陷入"内核态"，由操作系统代为执行。 + +``` +用户程序（用户态） + │ + │ write() 系统调用 + ↓ +内核（内核态） + │ + │ 操作硬件 + ↓ +磁盘 / 网卡 / 显示器 +``` + +为什么要这样？**安全**。 + +如果任何程序都能直接写磁盘，那恶意软件可以随意破坏文件系统。 +如果任何程序都能直接发网络包，那整个互联网都不安全。 + +系统调用就是在**权限边界上打一个受控的洞**： + +- 能力从这个洞里流进来（程序可以读写文件、发送网络请求） +- 风险也从这个洞里被隔住（内核审核每个请求，确保安全） + +典型的系统调用： + +| 操作 | 系统调用 | +|------|---------| +| 读文件 | `read(fd, buffer, count)` | +| 写文件 | `write(fd, buffer, count)` | +| 创建进程 | `fork()` / `exec()` | +| 分配内存 | `mmap()` / `brk()` | +| 网络通信 | `socket()` / `connect()` / `send()` | +| 访问设备 | `ioctl()` | + +### 3.2 Agent 世界里的系统调用 + +**Function Calling / Tool Use** 就是 Agent 的系统调用。 + +Agent（LLM）本身不能搜索网页、不能执行代码、不能访问数据库。它只能"推理"——根据输入生成输出。 + +要完成真实任务，必须通过 **Function Calling** 交给外部工具（Harness）执行： + +``` +Agent（LLM 推理） + │ + │ Function Call: search_web("...") + ↓ +Harness（执行环境） + │ + │ 执行工具 + ↓ +搜索引擎 / 代码执行器 / 数据库 +``` + +和操作系统一样，这也是一个**权限边界**： + +- LLM 本身不知道也不需要知道工具怎么实现的 +- Harness 负责审核、执行、返回结果 +- 安全策略在 Harness 层控制（哪些工具可用？频率限制？） + +### 3.3 详细对比 + +| 维度 | 操作系统 | Agent 系统 | +|------|---------|-----------| +| 执行主体 | CPU | LLM | +| 调用方式 | syscall | Function Calling / Tool Use | +| 执行环境 | 内核态 | Harness | +| 权限控制 | 用户ID、Capabilities | API Key、权限配置 | +| 资源隔离 | 进程/容器 | 沙箱、API 限制 | +| 审计 | 系统日志 | 调用日志、成本追踪 | + +### 3.4 Harness：Agent 的"内核" + +在很多 Agent 框架里，Harness 是核心组件： + +```python +class Harness: + def __init__(self): + self.tools = {} # 注册的工具 + self.policies = {} # 安全策略 + self.resources = {} # 资源配额 + + async def execute(self, tool_call: ToolCall) -> ToolResult: + # 1. 权限检查 + if not self._check_permission(tool_call): + raise PermissionError("Not authorized") + + # 2. 资源配额检查 + if not self._check_quota(tool_call): + raise ResourceExhaustedError("Quota exceeded") + + # 3. 执行工具 + tool = self.tools[tool_call.name] + result = await tool.execute(tool_call.args) + + # 4. 审计日志 + self._log(tool_call, result) + + return result +``` + +这不就是操作系统的系统调用处理逻辑吗？ + +```c +// 操作系统内核处理系统调用 +asmlinkage long sys_write(unsigned int fd, const char __user *buf, size_t count) { + // 1. 权限检查（capable(CAP_SYS_WRITE)?） + if (!capable(CAP_SYS_WRITE)) + return -EPERM; + + // 2. 参数验证（buf 是否用户空间指针？） + if (!access_ok(buf, count)) + return -EFAULT; + + // 3. 执行业务逻辑 + return vfs_write(fd, buf, count, &pos); + + // 4. 审计 + audit_syscall_entry(...); +} +``` + +### 3.5 工具定义的"ABI" + +操作系统有 ABI（Application Binary Interface）——函数调用的二进制约定。 + +Function Calling 有类似的约定——**工具的 schema**： + +```json +{ + "name": "search_web", + "description": "搜索互联网获取信息", + "parameters": { + "type": "object", + "properties": { + "query": { + "type": "string", + "description": "搜索关键词" + }, + "max_results": { + "type": "integer", + "description": "最多返回结果数", + "default": 10 + } + }, + "required": ["query"] + } +} +``` + +这就是 Agent 的"系统调用接口"。LLM 看到的工具定义，就像程序员看到的 man page。 + +--- + +## 肆、Cache / 虚拟内存 → Context Window + +### 4.1 操作系统里的内存层级 + +计算机的内存系统是一个**金字塔结构**： + +``` +金字塔顶部（最快、最贵、最小） +━━━━━━━━━━━━━━━━━━━━━━ + 寄存器 (~1 KB) 纳秒级 +━━━━━━━━━━━━━━━━━━━━━━ + L1 Cache (~32 KB) 纳秒级 +━━━━━━━━━━━━━━━━━━━━━━ + L2 Cache (~256 KB) 纳秒级 +━━━━━━━━━━━━━━━━━━━━━━ + L3 Cache (~8 MB) 十纳秒级 +━━━━━━━━━━━━━━━━━━━━━━ + 内存 RAM (~16 GB) 百纳秒级 +━━━━━━━━━━━━━━━━━━━━━━ + SSD (~1 TB) 微秒级 +━━━━━━━━━━━━━━━━━━━━━━ + 磁盘 (~10 TB) 毫秒级 +━━━━━━━━━━━━━━━━━━━━━━ +金字塔底部（最慢、最便宜、最大） +``` + +**核心问题**：资源是分层的，速度和容量永远矛盾。 + +解决方法：**缓存**和**虚拟内存**。 + +**缓存（Cache）**：把常用数据放在快但小的存储里。 + +**虚拟内存（Virtual Memory）**：把不常用的数据"换出"到慢但大的存储里。 + +```python +# 操作系统内存管理 +class MemoryManager: + def __init__(self, physical_memory, disk): + self.physical = physical_memory # 快速但有限 + self.disk = disk # 慢速但海量 + + def access(self, addr): + if addr in TLB: # Translation Lookaside Buffer + return self.physical[addr] # 命中，快！ + + page = self.page_table[addr] + if not page.in_memory: + # 页面置换：把不常用的页换出到磁盘 + victim = self.find_victim_page() + self.swap_out(victim) + self.swap_in(page) + + return self.physical[addr] +``` + +### 4.2 Context Window：Agent 的"内存" + +Context Window 就是 LLM 的"工作内存"。 + +当前最强模型也就 200K token 左右（GPT-4o），而这对于处理复杂任务来说其实很有限。 + +**类比映射**： + +| 操作系统 | Agent 世界 | +|---------|-----------| +| 寄存器 | 当前正在处理的 token | +| L1/L2 Cache | 最近几轮对话 | +| RAM | 完整对话上下文 | +| 虚拟内存/交换区 | 压缩摘要、外部存储 | +| 页面置换算法 | Context Compression | + +### 4.3 Context Compression：内存分页的 Agent 版 + +当 Context Window 快满的时候，必须做**压缩**或**摘要**： + +```python +class ContextManager: + def __init__(self, max_tokens=128000): + self.max_tokens = max_tokens + self.messages = [] + self.summaries = {} # 压缩后的摘要 + + def add_message(self, role, content): + self.messages.append({"role": role, "content": content}) + + # 检查是否超出限制 + current_tokens = self.count_tokens(self.messages) + + if current_tokens > self.max_tokens * 0.8: + # 触发压缩 + self._compress() + + def _compress(self): + # 方法1：简单截断（丢弃最早的对话） + while self.count_tokens(self.messages) > self.max_tokens * 0.5: + self.messages.pop(0) + + # 方法2：智能摘要（保留关键信息，压缩冗余） + # 用 LLM 本身生成摘要 + old_content = self._get_old_messages() + summary = self.llm.summarize(f"请总结以下对话的要点：\n{old_content}") + self.summaries["phase_1"] = summary + + # 方法3：分层记忆（工作记忆 vs 长期记忆） + working = self.messages[-10:] # 最近10轮 + longterm = self.summaries # 历史摘要 +``` + +**这不就是操作系统的"页面置换算法"吗？** + +操作系统用 LRU、FIFO、Clock 算法决定哪些页面该换出。 +Agent 用重要性、相关性、时效性决定哪些上下文该压缩。 + +### 4.4 分层记忆架构 + +借鉴操作系统的内存分层思想，可以设计 Agent 的分层记忆： + +``` +┌─────────────────────────────────────┐ +│ 工作记忆（Working Memory） │ ~4K tokens +│ 当前任务、最近对话、临时变量 │ +├─────────────────────────────────────┤ +│ 短期记忆（Short-term Memory） │ ~32K tokens +│ 今天/本周的会话、活跃项目上下文 │ +├─────────────────────────────────────┤ +│ 长期记忆（Long-term Memory） │ 外部存储 +│ 压缩摘要、用户偏好、历史经验 │ +└─────────────────────────────────────┘ +``` + +**类比**： + +- 工作记忆 = CPU 寄存器 + L1 Cache +- 短期记忆 = RAM +- 长期记忆 = 虚拟内存/SSD + +### 4.5 页面置换策略的 Agent 实践 + +操作系统有很多经典的页面置换算法： + +| 算法 | 思想 | Agent 对应 | +|------|------|-----------| +| LRU | 置换最久未使用的 | 置换最早对话 | +| LFU | 置换使用频率最低的 | 置换最少提及的概念 | +| FIFO | 置换最早的 | 置换时间最早的 | +| Working Set | 保留活跃页面 | 保留相关上下文 | + +**实践中的陷阱**： + +1. **热恋期问题**：Agent 在新对话开始时总是把所有历史都加载，导致 Context 膨胀 +2. **遗忘灾难**：过度压缩导致关键信息丢失 +3. **语义碎片化**：简单截断可能破坏语义完整性（比如截断到一句话中间） + +--- + +## 伍、文件系统挂载 → RAG + +### 5.1 操作系统里的文件系统 + +文件系统是操作系统最伟大的发明之一。 + +它把**物理存储设备**（磁盘、SSD、U盘、网络存储）抽象成**统一的文件树**： + +``` +/ （根目录） +├── home/ +│ └── user/ +│ ├── documents/ +│ │ ├── report.pdf +│ │ └── notes.txt +│ └── pictures/ +│ └── photo.jpg +├── etc/ +│ └── config.conf +└── tmp/ + └── cache.dat +``` + +**核心概念：挂载（Mount）** + +可以把任何存储设备挂载到文件树的任意位置： + +```bash +# 把 U 盘挂载到 /mnt/usb +mount /dev/sdb1 /mnt/usb + +# 把网络存储挂载到 /home/user/cloud +mount -t nfs 192.168.1.100:/share /home/user/cloud + +# 把 ISO 镜像挂载到 /mnt/iso +mount -o loop image.iso /mnt/iso +``` + +**按需加载**：文件不用时不占内存，访问时才从磁盘读取。 +**用完释放**：操作系统会在内存紧张时释放不常用的文件缓存。 + +### 5.2 RAG：Agent 的"文件系统挂载" + +**RAG（Retrieval-Augmented Generation）** 就是把外部知识库"挂载"到 Agent 的上下文中。 + +``` +┌─────────────────────────────────────────────┐ +│ Agent 的"文件系统树" │ +├─────────────────────────────────────────────┤ +│ /context ← 当前对话 │ +│ /memory ← 压缩记忆 │ +│ /knowledge ← RAG 挂载点 │ +│ │ ├── /company-docs ← 公司文档 │ +│ │ ├── /product-manual ← 产品手册 │ +│ │ └── /web-search-cache ← 搜索缓存 │ +│ /tools ← 可用工具 │ +└─────────────────────────────────────────────┘ +``` + +### 5.3 RAG 的工作原理 + +```python +class RAGSystem: + def __init__(self, vector_store, embedding_model): + self.store = vector_store # 向量数据库 + self.embed = embedding_model + + def retrieve(self, query: str, top_k: int = 5) -> List[Document]: + # 1. 把查询向量化 + query_embedding = self.embed.encode(query) + + # 2. 在向量数据库中搜索相似文档 + results = self.store.similarity_search( + query_embedding, + top_k=top_k + ) + + return results + + def mount_to_context(self, query: str) -> str: + # 1. 检索相关文档 + docs = self.retrieve(query) + + # 2. 组装成上下文 + context = "\n\n".join([doc.content for doc in docs]) + + # 3. 添加到 prompt + return f"参考信息：\n{context}\n\n用户问题：{query}" +``` + +### 5.4 类比总结 + +| 操作系统 | Agent 系统 | +|---------|-----------| +| 磁盘/SSD | 向量数据库（Milvus、Pinecone、Chroma） | +| 文件系统 | RAG 检索层 | +| mount 命令 | RAG 配置 / 知识库注册 | +| 文件 I/O | 向量相似度搜索 | +| 文件缓存 | 检索结果缓存 | +| 磁盘配额 | Token 预算控制 | + +### 5.5 进阶：多层存储架构 + +和操作系统一样，可以设计多层 RAG 存储： + +``` +┌─────────────────────────────────────────┐ +│ 热数据（Hot Storage） │ 实时检索 +│ 常用文档、高频访问内容 │ +├─────────────────────────────────────────┤ +│ 温数据（Warm Storage） │ 定期同步 +│ 近期文档、项目资料 │ +├─────────────────────────────────────────┤ +│ 冷数据（Cold Storage） │ 按需加载 +│ 历史归档、罕见参考资料 │ +└─────────────────────────────────────────┘ +``` + +--- + +## 陆、内核 / 调度器 → Harness / Orchestrator + +### 6.1 操作系统的内核 + +操作系统的**内核（Kernel）** 是整个系统的核心： + +- **资源管理**：CPU 时间片分配、内存分配、文件句柄、设备访问 +- **权限控制**：用户态/内核态切换、Capabilities、系统调用过滤 +- **进程调度**：决定哪个进程在哪个时刻运行 +- **进程通信**：信号、管道、消息队列、共享内存 + +**调度器（Scheduler）** 是内核最复杂的组件之一： + +```python +# 简化的调度器逻辑 +class Scheduler: + def __init__(self): + self.ready_queue = [] # 就绪队列 + self.running = None # 当前运行进程 + + def schedule(self): + # 1. 把已完成的进程移出 + if self.running and self.running.is_terminated(): + self.running = None + + # 2. 把等待 I/O 的进程放回就绪队列 + for proc in self.waiting: + if proc.is_io_complete(): + self.ready_queue.append(proc) + + # 3. 选择下一个进程运行 + if not self.running and self.ready_queue: + self.running = self.ready_queue.pop(0) + self.running.state = RUNNING + + # 4. 时间片用完，放回队列 + if self.running and self.running.used_full_timeslice(): + self.ready_queue.append(self.running) + self.running.state = READY + self.running = None +``` + +### 6.2 Harness：Agent 的"内核" + +在 Agent 架构里，Harness 扮演着类似内核的角色： + +```python +class Harness: + def __init__(self, llm, tools, memory): + self.llm = llm # LLM = "CPU" + self.tools = tools # 工具 = "系统调用" + self.memory = memory # 记忆 = "内存" + self.state = {} # Agent 状态 + self.quota = Quota() # 资源配额 + + async def execute(self, task: str) -> str: + # 1. 准备上下文 + context = await self._prepare_context(task) + + # 2. LLM 推理（可能多次） + while not self._is_complete(): + # LLM 生成下一步 + action = await self.llm.think(context) + + # 如果是系统调用，执行工具 + if action.is_tool_call(): + result = await self._execute_tool(action) + context.add_result(result) + else: + # 直接输出 + return action.content + + return context.final_answer() + + async def _execute_tool(self, tool_call: ToolCall): + # 权限检查 + if not self._check_permission(tool_call): + raise PermissionDenied() + + # 资源检查 + if not self.quota.can_use(tool_call): + raise QuotaExceeded() + + # 执行 + tool = self.tools[tool_call.name] + return await tool.execute(tool_call.args) +``` + +### 6.3 Orchestrator：多 Agent 的调度器 + +当多个 Agent 协作时，需要 **Orchestrator**（编排器）来协调： + +```python +class Orchestrator: + def __init__(self, agents: List[Agent], task_graph: Dict): + self.agents = agents + self.task_graph = task_graph # 任务依赖关系 + self.results = {} + + async def run(self, root_task: str) -> Any: + # 1. 构建执行计划（类似拓扑排序） + execution_order = self._topological_sort(root_task) + + # 2. 按顺序执行，支持并行 + executed = set() + + while executed != set(execution_order): + # 找出所有可以执行的 Agent（依赖已满足） + ready = [ + agent for agent in self.agents + if agent.name in execution_order + and agent.name not in executed + and all( + dep in executed + for dep in self._get_dependencies(agent) + ) + ] + + # 并行执行所有就绪的 Agent + if ready: + results = await asyncio.gather(*[ + agent.execute(self.results) for agent in ready + ]) + + for agent, result in zip(ready, results): + self.results[agent.name] = result + executed.add(agent.name) + else: + # 死锁检测 + raise DeadlockError("No agents can proceed") + + return self.results[root_task] +``` + +**这和操作系统的进程调度完全是一个套路：** + +1. 分析任务依赖（构建 DAG） +2. 拓扑排序得到执行顺序 +3. 并行执行无依赖的任务 +4. 收集结果，继续下一批 +5. 检测死锁（环形依赖） + +### 6.4 调度策略 + +操作系统有多种调度策略，Agent 系统也可以借鉴： + +| 调度策略 | OS 场景 | Agent 应用 | +|---------|--------|-----------| +| FCFS | 简单批处理 | 顺序执行任务 | +| SJF | 最短任务优先 | 优先执行简单的 Agent | +| Round Robin | 时间片轮转 | 多 Agent 轮流执行 | +| 优先级调度 | 重要任务优先 | 关键 Agent 优先执行 | +| 多级反馈队列 | 兼顾响应和效率 | 简单任务快速通道，复杂任务深度处理 | + +--- + +## 柒、安全模型：Capabilities vs 权限 + +### 7.1 操作系统的权限模型 + +操作系统用 **Capabilities** 或 **ACL（访问控制列表）** 来控制权限： + +```c +// Capabilities 模型 +struct process { + cap_t cap; // 进程的能力集 +}; + +// 检查是否有写文件权限 +if (!cap_raised(proc->cap, CAP_DAC_OVERRIDE)) { + return -EACCES; +} +``` + +用户程序只能做它被授权的事情。 + +### 7.2 Agent 的权限模型 + +```python +class ToolPermissions: + def __init__(self): + self.allowed_tools = set() + self.rate_limits = {} + self.data_scope = {} # 数据访问范围 + + def grant(self, tool: str, quota: dict): + self.allowed_tools.add(tool) + self.rate_limits[tool] = quota + + def check(self, agent: str, tool: str) -> bool: + return tool in self.allowed_tools + +# 使用示例 +permissions = ToolPermissions() +permissions.grant("web_search", {"per_minute": 10, "per_day": 100}) +permissions.grant("code_execution", {"per_hour": 50}) +permissions.grant("read_files", {"/data/public/*": True, "/data/private/*": False}) +``` + +--- + +## 捌、信号与中断 → 事件与回调 + +### 8.1 操作系统的中断机制 + +操作系统有**中断**机制来处理异步事件： + +- 硬件中断：键盘输入、网卡数据包、磁盘 I/O 完成 +- 软件中断：系统调用、异常、信号 + +```c +// 信号处理 +signal(SIGINT, handle_interrupt); // 注册 Ctrl+C 处理函数 + +void handle_interrupt(int sig) { + // 清理资源 + cleanup(); + exit(0); +} +``` + +### 8.2 Agent 的事件驱动 + +```python +class AgentEventSystem: + def __init__(self): + self.handlers = {} + self.event_queue = asyncio.Queue() + + def on(self, event: str, handler: Callable): + self.handlers[event] = handler + + async def emit(self, event: str, data: Any): + await self.event_queue.put({"event": event, "data": data}) + + async def process_events(self): + while True: + event = await self.event_queue.get() + handler = self.handlers.get(event["event"]) + if handler: + await handler(event["data"]) + +# 使用示例 +events = AgentEventSystem() +events.on("tool_result", on_tool_result) +events.on("context_full", on_context_full) +events.on("agent_error", on_agent_error) +``` + +--- + +## 玖、调试与日志：/proc 文件系统 vs Agent 观测性 + +### 9.1 /proc：窥探系统状态 + +Linux 的 `/proc` 文件系统让用户可以查看内核状态： + +```bash +cat /proc/1234/maps # 查看进程内存映射 +cat /proc/1234/status # 查看进程状态 +cat /proc/cpuinfo # CPU 信息 +cat /proc/meminfo # 内存信息 +``` + +### 9.2 Agent 的观测性 + +```python +class AgentObserver: + def __init__(self): + self.metrics = {} + + def log(self, event: AgentEvent): + self.metrics[event.type] = self.metrics.get(event.type, 0) + 1 + + def get_state(self, agent_id: str) -> dict: + return { + "agent_id": agent_id, + "current_task": self.get_current_task(agent_id), + "context_tokens": self.count_tokens(agent_id), + "tools_used": self.get_tools_used(agent_id), + "execution_time": self.get_elapsed_time(agent_id), + "errors": self.get_errors(agent_id) + } + + def dump_trace(self, agent_id: str) -> str: + # 返回完整的执行轨迹，用于调试 + return json.dumps(self.trace[agent_id], indent=2) +``` + +--- + +## 拾、容器与命名空间 → Agent 隔离 + +### 10.1 容器技术 + +Docker 和 Kubernetes 重新定义了"进程隔离"： + +- **PID Namespace**：容器内的进程 ID 从 1 开始 +- **Network Namespace**：容器有独立的网络栈 +- **Mount Namespace**：容器有独立的文件系统视图 +- **User Namespace**：容器内的用户 ID 可以映射到主机不同位置 + +```bash +# Docker 的隔离 +docker run --pid=host nginx # 共享 PID 命名空间 +docker run --network=host nginx # 共享网络命名空间 +docker run -v /host/path:/container/path nginx # 共享挂载 +``` + +### 10.2 Agent 隔离 + +类似地，Agent 系统也可以有不同级别的隔离： + +```python +class AgentSandbox: + def __init__(self, isolation_level: str): + self.isolation = isolation_level + + # 完全隔离：独立记忆和工具 + FULL = "full" + + # 共享工具，隔离记忆 + SHARED_TOOLS = "shared_tools" + + # 共享记忆，隔离工具 + SHARED_MEMORY = "shared_memory" + + # 完全共享（危险！） + NONE = "none" +``` + +--- + +## 拾壹、未来展望 + +### 11.1 Agent 操作系统？ + +我在想一个问题：会不会有一天，出现类似"Agent OS"的东西？ + +- **进程** = Agent +- **文件系统** = 去中心化的知识图谱 +- **系统调用** = 标准化的 Tool Interface +- **调度器** = Orchestrator +- **安全沙箱** = Capability-based Access Control + +这不是科幻。事实上，很多框架已经在朝这个方向走： + +- LangGraph 的状态机 +- AutoGPT 的任务分解 +- CrewAI 的 Agent 协作 +- Microsoft AutoGen 的会话编排 + +### 11.2 我们能从 OS 历史学到什么？ + +操作系统几十年沉淀下来的智慧： + +1. **分层抽象**：不要让每个层知道太多上层细节 +2. **最小权限原则**：只授予完成任务所需的最小权限 +3. **fail-safe 设计**：出错了要安全地失败，不要搞垮整个系统 +4. **可观测性**：运行时能看见内部状态，出了问题才能排查 +5. **资源隔离**：防止一个组件拖垮整个系统 + +这些问题，Agent 时代正在重新面对。 + +--- + +## 结语：历史不会重复，但会押韵 + +马克·吐温说：**"历史不会重复，但会押韵。"** + +操作系统花了几十年，从裸机编程演进到现代多任务系统： +- 进程隔离解决了安全问题 +- 虚拟内存解决了容量问题 +- 文件系统解决了存储抽象问题 +- 调度器解决了资源分配问题 + +Agent 时代正在用同样的方式重新走这条路： +- Agent 隔离解决协作问题 +- Context Compression 解决容量问题 +- RAG 解决知识抽象问题 +- Orchestrator 解决任务分配问题 + +当你觉得某个 Agent 设计似曾相识—— + +**不妨回到操作系统教科书里找答案。那里面藏着你需要的解。** + +--- + +*如果你觉得这篇文章有帮助，欢迎分享给同样在学习 Agent 的朋友。* + +*历史在押韵，我们都是见证者。* \ No newline at end of file diff --git a/博客/AI与大模型/学习Agent，越学越像在重新理解操作系统.md b/博客/AI与大模型/学习Agent，越学越像在重新理解操作系统.md new file mode 100644 index 0000000..54ebb1a --- /dev/null +++ b/博客/AI与大模型/学习Agent，越学越像在重新理解操作系统.md @@ -0,0 +1,105 @@ +--- +title: 学习 Agent，越学越像在重新理解操作系统 +id: c11d5916-8c13-498f-a208-bc2287fb885d +date: 2026-04-30 17:07:24 +auther: liuhangyv +cover: +excerpt: 学习 Agent，越学越像在重新理解操作系统 引言 学了半年 Agent 框架，我产生了一个奇怪的感觉：我好像在重新学操作系统。 进程与线程、文件系统、系统调用、内存分页、调度器……这些操作系统里的经典概念，几乎都能在 Agent 系统中找到一一对应的存在。今天就来聊聊这个有趣的类比。 进程与线程 +permalink: /archives/xue-xi-agent-yue-xue-yue-xiang-zai-chong-xin-li-jie-cao-zuo-xi-tong +categories: + - xing-ye-wang-yuan-jing +tags: + - ji-shu-shen-qian + - aizhi-neng-ti +--- + +# 学习 Agent，越学越像在重新理解操作系统 + +## 引言 + +学了半年 Agent 框架，我产生了一个奇怪的感觉：**我好像在重新学操作系统**。 + +进程与线程、文件系统、系统调用、内存分页、调度器……这些操作系统里的经典概念，几乎都能在 Agent 系统中找到一一对应的存在。今天就来聊聊这个有趣的类比。 + +## 进程与线程 → Sub-Agent + +操作系统里，**进程是资源边界，线程是执行单元**。同进程的线程共享内存，跨进程则要显式通信。 + +Agent 世界完全照搬了这套做法。当我们用 Sub-Agent 让多个 Agent 并行协作，立刻面对经典问题：**谁能访问谁的状态？** + +共享上下文带来效率，也带来竞争条件。死锁、竞争、一致性……这些老问题穿着新衣服又回来了。 + +> 一个 Sub-Agent 正在写文件，另一个 Sub-Agent 同时在读同一个变量——这就是经典的 race condition。 + +## 系统调用 → Tool Use + +这是最像的一个类比。 + +**用户程序想访问硬件，不能直接碰，必须通过系统调用陷入内核，由内核代为执行。** + +Agent 想搜网页、跑代码、查数据库，也不能自己动，必须通过 Function Calling 交给 Harness 执行。 + +两者的本质完全一样：**在权限边界上打一个受控的洞，能力从这个洞里流进来，风险也从这个洞里被隔住。** + +| 操作系统 | Agent 系统 | +|---------|-----------| +| 系统调用 | Function Calling / Tool Use | +| 内核态 | Harness 执行环境 | +| 用户态 | LLM 推理过程 | +| 硬件设备 | 外部工具（搜索、代码执行、数据库） | + +## Cache / 虚拟内存 → Context Window + +Context Window 是 Agent 最稀缺的资源，贵到每个 token 都要精打细算。 + +这和 CPU Cache 的逻辑一模一样： + +- **寄存器** → 当前正在推理的内容 +- **L1/L2 Cache** → 近期对话上下文 +- **内存** → 长期记忆中的最近会话 +- **磁盘/交换区** → 压缩摘要或外部存储 + +当上下文满了，Agent 框架开始做 **Context Compression**——这就是在做**内存分页与交换**，只不过换出去的不是字节，是语义。 + +> "这段对话太长，我把关键信息压缩成一个摘要存着" = "内存不足，把不常用的页面换出到磁盘" + +## 文件系统挂载 → RAG + +**RAG 把外部知识库挂进 Agent 的"文件树"**，需要时检索，不需要时不占窗口。 + +这和操作系统挂载外部存储的逻辑完全相同：**用廉价的大容量存储补偿昂贵的快速内存，按需加载，用完释放。** + +| 操作系统 | Agent 系统 | +|---------|-----------| +| 磁盘/SSD | 外部知识库（向量数据库） | +| 文件系统 | RAG 检索层 | +| mount 命令 | RAG 配置 | +| 磁盘 I/O | 向量相似度搜索 | + +## 内核 / 调度器 → Harness / Orchestrator + +**Agent = Model + Harness** + +Model 是计算本身，Harness 是操作系统内核：管权限、调度任务、分配资源、处理工具调用的返回。 + +多 Agent 系统里的 **Orchestrator** 就是调度器，决定： +- 哪个 Agent 先跑 +- 跑多久 +- 结果传给谁 + +换个场景照样适用——这就是操作系统的任务调度。 + +## 写在最后 + +操作系统花了几十年才把这些问题想清楚：进程隔离、内存管理、文件系统抽象、设备驱动…… + +**Agent 时代正在把同样的问题重新答一遍。** + +只不过： +- 资源从 **CPU / 内存** 变成了 **token / 推理时间** +- "程序" 从**机器指令**变成了**自然语言** +- "进程" 从**隔离的地址空间**变成了**独立的 Agent 实例** + +历史不会重复，但会押韵。 + +当你觉得某个 Agent 设计似曾相识——不妨回到操作系统教科书里找答案。那里面藏着你需要的解。 \ No newline at end of file